I’m running delayed() on several fuctions and passing that to run() as a list of delayed functions.
When it fails I see in the logger:
distributed.worker - WARNING - Compute Failed
Exception: blah blah blah
However I actually want it to wait and raise an exception. It does not seem to ever hit the exception handler although the code looks like
try: list_of_delayed = [c.delayed(xxxx)(), c.delayed(yyyy)() ] c.run(list_of_delayed) except Exception as e: # never hits it
How do I get it to wait and raise an exception? Dask client is set to async. The run() default kwargs are used and I see
on_error: Literal['raise', 'return', 'ignore'] = 'raise' so I thought it would raise the exception from the caller.