cleanup
This commit is contained in:
@ -90,15 +90,18 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
|
|||||||
except Exception as e:
|
except Exception as e:
|
||||||
print(f"({pulseid}) problem ({e}) to read peakfinder parameters file, worker : {worker}", flush=True)
|
print(f"({pulseid}) problem ({e}) to read peakfinder parameters file, worker : {worker}", flush=True)
|
||||||
|
|
||||||
|
|
||||||
if not zmq_socks.has_data():
|
if not zmq_socks.has_data():
|
||||||
continue
|
continue
|
||||||
|
|
||||||
image, metadata = zmq_socks.get_data()
|
image, metadata = zmq_socks.get_data()
|
||||||
|
|
||||||
results = copy(metadata)
|
if metadata["shape"] == [2, 2]: # this is used as marker for empty images
|
||||||
if results["shape"][0] == 2 and results["shape"][1] == 2:
|
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
results = metadata.copy()
|
||||||
|
|
||||||
|
|
||||||
pulseid = results.get("pulse_id", 0)
|
pulseid = results.get("pulse_id", 0)
|
||||||
results.update(peakfinder_parameters)
|
results.update(peakfinder_parameters)
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user