def failed_tuple(self, stream_id, source_component, latency_in_ns):
self.update_count(self.FAIL_COUNT, key=stream_id)<EOL>self.update_reduced_metric(self.FAIL_LATENCY, latency_in_ns, stream_id)<EOL>global_stream_id = source_component + '<STR_LIT:/>' + stream_id<EOL>self.update_count(self.FAIL_COUNT, key=global_stream_id)<EOL>self.update_reduced_metric(self.FAIL_LATENCY, latency_in_ns, global_stream_id)<EOL>
Apply updates to the fail metrics