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

early exit 1

Browse Source
This commit is contained in:
augustin_s
2024-08-08 16:07:54 +02:00
parent 7987125bf5
commit a7327ddbf7
1 changed files with 31 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
dap/algos/forcesend.py
View File

@ -4,41 +4,43 @@ import numpy as np
def calc_force_send(results, data, pixel_mask_pf, image, n_aggregated_images, data_summed): def calc_force_send(results, data, pixel_mask_pf, image, n_aggregated_images, data_summed):
force_send_visualisation = False force_send_visualisation = False
if data.dtype != np.uint16: if data.dtype == np.uint16:
apply_threshold = results.get("apply_threshold", False) return data, force_send_visualisation, n_aggregated_images, data_summed
apply_aggregation = results.get("apply_aggregation", False)
if not apply_aggregation: apply_threshold = results.get("apply_threshold", False)
data_summed = None apply_aggregation = results.get("apply_aggregation", False)
n_aggregated_images = 1
if apply_threshold or apply_aggregation: if not apply_aggregation:
if apply_threshold and all(k in results for k in ("threshold_min", "threshold_max")): data_summed = None
threshold_min = float(results["threshold_min"]) n_aggregated_images = 1
threshold_max = float(results["threshold_max"])
data[data < threshold_min] = 0.0
if threshold_max > threshold_min:
data[data > threshold_max] = 0.0
if apply_aggregation and "aggregation_max" in results: if apply_threshold or apply_aggregation:
if data_summed is not None: if apply_threshold and all(k in results for k in ("threshold_min", "threshold_max")):
data += data_summed threshold_min = float(results["threshold_min"])
n_aggregated_images += 1 threshold_max = float(results["threshold_max"])
data_summed = data.copy() data[data < threshold_min] = 0.0
data_summed[data == -np.nan] = -np.nan #TODO: this does nothing if threshold_max > threshold_min:
results["aggregated_images"] = n_aggregated_images data[data > threshold_max] = 0.0
results["worker"] = 1 #TODO: keep this for backwards compatibility?
if n_aggregated_images >= results["aggregation_max"]: if apply_aggregation and "aggregation_max" in results:
force_send_visualisation = True if data_summed is not None:
data_summed = None data += data_summed
n_aggregated_images = 1 n_aggregated_images += 1
data_summed = data.copy()
data_summed[data == -np.nan] = -np.nan #TODO: this does nothing
results["aggregated_images"] = n_aggregated_images
results["worker"] = 1 #TODO: keep this for backwards compatibility?
if pixel_mask_pf is not None: if n_aggregated_images >= results["aggregation_max"]:
data[~pixel_mask_pf] = np.nan force_send_visualisation = True
data_summed = None
n_aggregated_images = 1
else: if pixel_mask_pf is not None:
data = image data[~pixel_mask_pf] = np.nan
else:
data = image
return data, force_send_visualisation, n_aggregated_images, data_summed return data, force_send_visualisation, n_aggregated_images, data_summed