From 432dab23fb767350a24d9437e88aaf35e3093902 Mon Sep 17 00:00:00 2001 From: wyzula-jan <133381102+wyzula-jan@users.noreply.github.com> Date: Wed, 9 Aug 2023 11:40:30 +0200 Subject: [PATCH] feat: metadata available on_dap_update --- bec_plugins/data_processing/px_streamer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/bec_plugins/data_processing/px_streamer.py b/bec_plugins/data_processing/px_streamer.py index 6bd84d8..012663d 100644 --- a/bec_plugins/data_processing/px_streamer.py +++ b/bec_plugins/data_processing/px_streamer.py @@ -13,9 +13,9 @@ def load_data() -> tuple: Returns """ proj_nr = 180 - basedir = f"/home/appel_c/Documents/test_data/projection_{proj_nr:06d}/" + basedir = f"/Users/janwyzula/PSI/test_data_reduced/projection_{proj_nr:06d}/" - metadata_name = f"/home/appel_c/Documents/test_data/projection_{proj_nr:06d}.json" + metadata_name = f"/Users/janwyzula/PSI/test_data_reduced/projection_{proj_nr:06d}.json" with open(metadata_name) as file: metadata = json.load(file) @@ -77,6 +77,6 @@ if __name__ == "__main__": proj_nr = 180 while True: send_data(data, q, norm_sum, bec_producer, metadata, proj_nr=proj_nr) - time.sleep(30) + time.sleep(20) bec_producer.delete(topic=f"px_stream/projection_{proj_nr}/data:val") # proj_nr = proj_nr + 1