Skip to content

Commit

Permalink
Merge pull request #112 from achandrashekhar-splunk/undo-changes-for-…
Browse files Browse the repository at this point in the history
…computation-py

Undo unintended changes from #105
  • Loading branch information
mahdibh authored Aug 27, 2020
2 parents 6505e9f + 1f523ea commit 1adebb8
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions signalfx/signalflow/computation.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 1adebb8

Please sign in to comment.