diff --git a/dap/utils/bufjson.py b/dap/utils/bufjson.py index 7ac7be6..7e6fcfe 100644 --- a/dap/utils/bufjson.py +++ b/dap/utils/bufjson.py @@ -17,6 +17,7 @@ class BufferedJSON: if time_delta <= 2: #TODO: is that a good time? return self.last_data + #TODO: logging for change? sleep(0.5) #TODO: why? current_data = self.get_data() self.last_time = current_time diff --git a/dap/worker.py b/dap/worker.py index 9c982ce..2dfbfd7 100644 --- a/dap/worker.py +++ b/dap/worker.py @@ -51,16 +51,10 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host while True: - -# check if peakfinder parameters changed and then re-read it try: peakfinder_parameters = bj_peakfinder_parameters.load() -# if worker == 0: -# print(f"({pulse_id}) update peakfinder parameters {old_peakfinder_parameters}", flush=True) -# print(f" --> {peakfinder_parameters}", flush=True) -# print(flush=True) except Exception as e: - print(f"({pulse_id}) problem ({e}) to read peakfinder parameters file", flush=True) + print(f"({pulse_id}) cannot read peakfinder parameters file: {e}", flush=True) #TODO: logging? if not zmq_socks.has_data():