From da68de868ca008d83329c398ed0d0677a811b621 Mon Sep 17 00:00:00 2001
From: Patrick Godwin <patrick.godwin@ligo.org>
Date: Wed, 18 Jul 2018 08:49:52 -0700
Subject: [PATCH] gstlal_feature_synchronizer: fix issue with features getting
mangled before getting sent downstream
---
gstlal-burst/bin/gstlal_feature_synchronizer | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/gstlal-burst/bin/gstlal_feature_synchronizer b/gstlal-burst/bin/gstlal_feature_synchronizer
index b64e00d3da..db48addc0e 100755
--- a/gstlal-burst/bin/gstlal_feature_synchronizer
+++ b/gstlal-burst/bin/gstlal_feature_synchronizer
@@ -166,7 +166,7 @@ class StreamSynchronizer(object):
combine subsets of features from multiple streams in a sensible way
"""
datum = [subset[1] for subset in subsets]
- return list(itertools.chain(*datum))
+ return {ch: rows for channel_subsets in datum for ch, rows in channel_subsets.items()}
def push_features(self):
"""
@@ -176,7 +176,7 @@ class StreamSynchronizer(object):
if self.feature_buffer:
timestamp, features = self.feature_buffer.pop()
logger.info('pushing features with timestamp %d downstream' % timestamp)
- feature_packet = {'timestamp': timestamp, 'features': list(features)}
+ feature_packet = {'timestamp': timestamp, 'features': features}
self.producer.produce(timestamp = timestamp, topic = self.producer_name, value = json.dumps(feature_packet))
def max_timeout(self):
--
GitLab