From 1f523ea04c235a3341406e2ed80d5282bd92c312 Mon Sep 17 00:00:00 2001 From: Aishwarya Date: Thu, 27 Aug 2020 10:23:56 -0700 Subject: [PATCH] Undo changes from previous PR and fix issue for for multi data block components --- signalfx/signalflow/computation.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/signalfx/signalflow/computation.py b/signalfx/signalflow/computation.py index 3c6b1a5..a1f3317 100644 --- a/signalfx/signalflow/computation.py +++ b/signalfx/signalflow/computation.py @@ -166,9 +166,8 @@ def stream(self): self._process_info_message(message.message) self._batch_count_detected = True yield message - # TODO: InfoMessages are coming before DataMessages - # if self._current_batch_message: - # yield self._get_batch_to_yield() + if self._current_batch_message: + yield self._get_batch_to_yield() continue # Accumulate data messages and release them when we have received