diff --git a/gstlal-burst/bin/gstlal_feature_monitor b/gstlal-burst/bin/gstlal_feature_monitor index 54fdde034b0515ee67c6a1f272c41a462c90d174..a5fd5d11cd039c97d043516385ed65c156c29b25 100755 --- a/gstlal-burst/bin/gstlal_feature_monitor +++ b/gstlal-burst/bin/gstlal_feature_monitor @@ -173,7 +173,7 @@ class StreamMonitor(object): for metric in ('latency', 'percent_missed'): self.agg_sink.store_and_reduce(metric, {'synchronizer': [metrics['time'], metrics[metric]]}, 'data', tags='job', aggregates=self.data_type) if len(metrics['target_time']) > 0: - self.agg_sink.store_and_reduce(metric, {'synchronizer': [metrics['target_time'], metrics['target_snr']]}, 'data', tags='job', aggregates=self.data_type) + self.agg_sink.store_and_reduce('target_snr', {'synchronizer': [metrics['target_time'], metrics['target_snr']]}, 'data', tags='job', aggregates=self.data_type) self.last_save = timestamp logger.info('processed features up to timestamp %.3f, max latency = %.3f s' % (timestamp, max(metrics['latency'])))