sf-daq/sf_daq_broker
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_broker.git synced 2026-05-08 08:02:03 +02:00
Code Issues Packages Projects Releases Wiki Activity

made the structure of data_request more apparent

Browse Source
This commit is contained in:
augustin_s
2024-02-12 12:37:05 +01:00
committed by Auf keinen Fall Jens
parent 466bdd6ef0
commit eb63e5c91c
1 changed files with 13 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf_daq_broker/writer/post_retrieve.py
+13 -11
View File
@@ -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)