Commit f19756ca authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

remove printouts

parent 0fe7c647
......@@ -161,10 +161,8 @@ class SerialAsapoReceiver(SimpleAsapoReceiver):
def _get_next(self, meta_only, receive_dataset):
log.info("Requesting next record for group_id=%s.", self.group_id)
print("receive_dataset: ", receive_dataset)
try:
if receive_dataset:
print("Bla")
current_id, metadata = self.broker.get_next_dataset(
self.group_id, substream=self.substream)
data = []
......
......@@ -166,6 +166,7 @@ class Streamer:
while not self.stopped.is_set():
data, substream_metadata = self._get_substream_metadata()
if substream_metadata:
substream_metadata['meta']['substream'] = self.receiver.substream
self._reset_delay_on_error()
break
if self.likely_done:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment