Commit 638c18de authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

Merge branch 'fix/callback' into 'master'

Fix: callback and workers without metadata stream

See merge request !27
parents cb8f8b40 3e64a104
......@@ -179,6 +179,7 @@ class AsapoSender:
self.producer.send_stream_finished_flag(stream=self.stream, last_id=last_id, next_stream=next_stream)
def _callback(self, header, err):
header = {key: val for key, val in header.items() if key != 'data'}
with self._lock:
assert self._n_queued > 0
self._n_queued -= 1
......
......@@ -50,7 +50,8 @@ def get_new_stream(stream, receiver_stream_list, metadata_stream_list,
receiver_stream_list = sorted(receiver_stream_list, key=lambda x: x['timestampCreated'])
receiver_stream_list = [x['name'] for x in receiver_stream_list]
metadata_stream_list = [x['name'] for x in metadata_stream_list]
if isinstance(metadata_stream_list, list):
metadata_stream_list = [x['name'] for x in metadata_stream_list]
if 'basename' in naming_scheme:
if sender_stream_list is None:
log.warning(
......
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