sf-daq/dap
0
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

simpler logic

Browse Source
This commit is contained in:
augustin_s
2024-08-09 14:54:30 +02:00
parent a7429115d7
commit f12a736355
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
dap/algos/forcesend.py
View File

@ -56,10 +56,14 @@ def calc_apply_aggregation(results, data, data_summed, n_aggregated_images):
if "aggregation_max" not in results: if "aggregation_max" not in results:
return data, force_send_visualisation, data_summed, n_aggregated_images return data, force_send_visualisation, data_summed, n_aggregated_images
if data_summed is not None: if data_summed is None:
data += data_summed data_summed = data.copy()
n_aggregated_images = 1
else:
data_summed += data
n_aggregated_images += 1 n_aggregated_images += 1
data_summed = data.copy()
data = data_summed
results["aggregated_images"] = n_aggregated_images results["aggregated_images"] = n_aggregated_images
results["worker"] = 1 #TODO: keep this for backwards compatibility? results["worker"] = 1 #TODO: keep this for backwards compatibility?