added pulse ID to bsread sending logging; added config file name to worker logging
This commit is contained in:
@@ -73,7 +73,7 @@ def accumulate(accumulator_addr, bsread_host, bsread_port, bsread_window):
|
||||
try:
|
||||
sender.send(pulse_id=pulse_id, timestamp=timestamp, data=data)
|
||||
except:
|
||||
log.exception(f"bsread failed to send: {data}")
|
||||
log.exception(f"{pulse_id} bsread failed to send: {data}")
|
||||
|
||||
|
||||
|
||||
|
||||
@@ -69,7 +69,7 @@ def work(backend_addr, accumulator_addr, visualisation_addr, fn_config, skip_fra
|
||||
try:
|
||||
config = config_file.load()
|
||||
except:
|
||||
log.exception(f"({pulse_id}) cannot read config file")
|
||||
log.exception(f"({pulse_id}) cannot read config file: {config_file.fname}")
|
||||
|
||||
|
||||
results = metadata.copy()
|
||||
|
||||
Reference in New Issue
Block a user