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

removed commented part and reworded printout; todo notes

Browse Source
This commit is contained in:
augustin_s
2024-08-07 17:27:42 +02:00
parent a184e49eee
commit 0914b8d169
2 changed files with 2 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
dap/utils/bufjson.py
View File

@ -17,6 +17,7 @@ class BufferedJSON:
if time_delta <= 2: #TODO: is that a good time? if time_delta <= 2: #TODO: is that a good time?
return self.last_data return self.last_data
#TODO: logging for change?
sleep(0.5) #TODO: why? sleep(0.5) #TODO: why?
current_data = self.get_data() current_data = self.get_data()
self.last_time = current_time self.last_time = current_time

8
dap/worker.py
View File

@ -51,16 +51,10 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
while True: while True:
# check if peakfinder parameters changed and then re-read it
try: try:
peakfinder_parameters = bj_peakfinder_parameters.load() 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: 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(): if not zmq_socks.has_data():