Commit 26387cde authored by Tim Schoof's avatar Tim Schoof
Browse files

Fix workers without metadata stream

This is a temporary hack until the different stream naming schemes
become obsolete due to further improvements like acknowledgements.
parent db85b614
Pipeline #5044 passed with stage
in 48 seconds
...@@ -50,7 +50,8 @@ def get_new_stream(stream, receiver_stream_list, metadata_stream_list, ...@@ -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 = sorted(receiver_stream_list, key=lambda x: x['timestampCreated'])
receiver_stream_list = [x['name'] for x in receiver_stream_list] receiver_stream_list = [x['name'] for x in receiver_stream_list]
metadata_stream_list = [x['name'] for x in metadata_stream_list] if not isinstance(metadata_stream_list, ContainsAll):
metadata_stream_list = [x['name'] for x in metadata_stream_list]
if 'basename' in naming_scheme: if 'basename' in naming_scheme:
if sender_stream_list is None: if sender_stream_list is None:
log.warning( log.warning(
......
Markdown is supported
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