From 6b76262fc8e4e1d25bc51b9e9470fb1c31883caa Mon Sep 17 00:00:00 2001
From: Diana Rueda <diana.rueda@desy.de>
Date: Tue, 21 May 2024 17:32:36 +0200
Subject: [PATCH] Add suggested changes on consume.py
---
docs/site/examples/python/consume.py | 17 +++++------------
1 file changed, 5 insertions(+), 12 deletions(-)
diff --git a/docs/site/examples/python/consume.py b/docs/site/examples/python/consume.py
index 760a4d8b0..6678e83a0 100644
--- a/docs/site/examples/python/consume.py
+++ b/docs/site/examples/python/consume.py
@@ -13,7 +13,7 @@ token = str(
consumer = asapo_consumer.create_consumer(
server_name="localhost:8400",
source_path="auto",
- has_filesystem=False,
+ has_filesystem=False, # Ignore for now
beamtime_id="asapo_test", # Same as for the producer
data_source="test_source", # Same as for the producer
token=token,
@@ -26,17 +26,10 @@ consumer = asapo_consumer.create_consumer(
# list snippet_start
for stream in consumer.get_stream_list():
print(
- "Stream name: ",
- stream["name"],
- "\n",
- "LastId: ",
- stream["lastId"],
- "\n",
- "Stream finished: ",
- stream["finished"],
- "\n",
- "Next stream: ",
- stream["nextStream"],
+ f"Stream name: {stream['name']}\n"
+ f"LastId: {stream['lastId']}\n"
+ f"Stream finished: {stream['finished']}\n"
+ f"Next stream: {stream['nextStream']}"
)
# list snippet_end
--
GitLab