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

use that BufferedJSON works for non-existing files

Browse Source
This commit is contained in:
augustin_s
2024-08-07 17:05:30 +02:00
parent 8531f0a28d
commit a184e49eee
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
dap/worker.py
View File

@ -1,5 +1,4 @@
import argparse
import os
from random import randint
import numpy as np
@ -38,11 +37,7 @@ def main():
def work(backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port, fn_peakfinder_parameters, skip_frames_rate):
peakfinder_parameters = {}
bj_peakfinder_parameters = None
if fn_peakfinder_parameters is not None and os.path.exists(fn_peakfinder_parameters):
bj_peakfinder_parameters = BufferedJSON(fn_peakfinder_parameters)
bj_peakfinder_parameters = BufferedJSON(fn_peakfinder_parameters)
jfdata = JFData()
@ -59,8 +54,7 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
# check if peakfinder parameters changed and then re-read it
try:
if bj_peakfinder_parameters:
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)