From eb63e5c91cfdfc4593cd123739474728ec5eab6e Mon Sep 17 00:00:00 2001 From: Sven Augustin Date: Mon, 12 Feb 2024 12:37:05 +0100 Subject: [PATCH] made the structure of data_request more apparent --- sf_daq_broker/writer/post_retrieve.py | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) diff --git a/sf_daq_broker/writer/post_retrieve.py b/sf_daq_broker/writer/post_retrieve.py index f1b1258..8e53b04 100644 --- a/sf_daq_broker/writer/post_retrieve.py +++ b/sf_daq_broker/writer/post_retrieve.py @@ -67,17 +67,19 @@ def post_retrieve(source, fn_run_info): channels = run_info[entry_name] - data_request = {} - data_request["range"] = {} - data_request["range"]["startPulseId"] = run_info["start_pulseid"] - data_request["range"]["endPulseId"] = run_info["stop_pulseid"] - data_request["channels"] = [ - { - "name": ch, - "backend": config.IMAGE_BACKEND if ch.endswith(":FPICTURE") else config.DATA_BACKEND - } - for ch in channels - ] + data_request = { + "range": { + "startPulseId": run_info["start_pulseid"], + "endPulseId": run_info["stop_pulseid"] + }, + "channels": [ + { + "name": ch, + "backend": config.IMAGE_BACKEND if ch.endswith(":FPICTURE") else config.DATA_BACKEND + } + for ch in channels + ] + } run_number = run_info.get("run_number", 0) acquisition_number = run_info.get("acquisition_number", 0)