diff --git a/dap/worker.py b/dap/worker.py index 69ed855..ae811f4 100644 --- a/dap/worker.py +++ b/dap/worker.py @@ -128,9 +128,10 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host apply_aggregation = results.get("apply_aggregation", False) send_empty_cond1 = (apply_aggregation and "aggregation_max" in results and not force_send_visualisation) - send_empty_cond2 = (not results["is_good_frame"] or not (results["is_hit_frame"] or randint(1, skip_frames_rate) == 1)) + send_empty_cond2 = (not results["is_good_frame"]) + send_empty_cond3 = (not (results["is_hit_frame"] or randint(1, skip_frames_rate) == 1)) - if send_empty_cond1 or send_empty_cond2: + if send_empty_cond1 or send_empty_cond2 or send_empty_cond3: data = np.empty((2, 2), dtype=np.uint16) results["type"] = str(data.dtype) results["shape"] = data.shape