Skip to content
Snippets Groups Projects
Commit 6b76262f authored by Diana Rueda's avatar Diana Rueda
Browse files

Add suggested changes on consume.py

parent 10704b13
No related branches found
No related tags found
No related merge requests found
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment