From 32f50c30e79406d84437328cfe0ec9504b9ffd46 Mon Sep 17 00:00:00 2001
From: Sergey Yakubov <sergey.yakubov@desy.de>
Date: Mon, 3 May 2021 21:20:48 +0200
Subject: [PATCH] fix test
---
.../streamlist_python_multithread/magic_producer.py | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/tests/automatic/bug_fixes/streamlist_python_multithread/magic_producer.py b/tests/automatic/bug_fixes/streamlist_python_multithread/magic_producer.py
index 3f658c261..97f38c68e 100644
--- a/tests/automatic/bug_fixes/streamlist_python_multithread/magic_producer.py
+++ b/tests/automatic/bug_fixes/streamlist_python_multithread/magic_producer.py
@@ -8,12 +8,13 @@ import sys
endpoint, beamtime, token = sys.argv[1:]
+
def dummy_producer(data_source):
def callback(header, err):
if err is not None:
print("could not sent: ", header, err)
-# else:
-# print("successfuly sent: ", header)
+ # else:
+ # print("successfuly sent: ", header)
producer = asapo_producer.create_producer(endpoint, 'processed', beamtime, 'auto', data_source, '', 5,
60000) # source type 'processed' to write to the core filesystem
producer.set_log_level("none")
@@ -21,15 +22,15 @@ def dummy_producer(data_source):
for j in range(5):
stream = datetime.now().strftime('%Y%m%dT_%H%M%S')
-# print(f"{data_source} new stream {stream}")
for i in range(5):
- producer.send(i + 1, f"{data_source}_{stream}_{i}", None,
+ producer.send(i + 1, data_source + "_" + stream + "_" + str(i), None,
callback=callback,
ingest_mode=asapo_producer.INGEST_MODE_TRANSFER_METADATA_ONLY,
stream=stream)
sleep(0.6)
producer.send_stream_finished_flag(stream=stream, last_id=i + 1)
- print(j+1,": number of streams",f"{data_source}: ", len(consumer.get_stream_list()))
+ print(j + 1, ": number of streams", data_source + ": ", len(consumer.get_stream_list()))
+
def main():
with ThreadPoolExecutor(max_workers=3) as executor:
--
GitLab