79101474

Date: 2024-10-18 09:40:53
Score: 1
Natty:
Report link

Structured logs can help here, example from the documentation:

def myfunc(x):
    start = time()
    ...
    stop = time()
    dask.distributed.get_worker().log_event("runtimes", {"start": start, "stop": stop})

futures = client.map(myfunc, range(10))
client.get_events("runtimes")
Reasons:
  • Probably link only (1):
  • Low length (0.5):
  • Has code block (-0.5):
Posted by: mateuszb