This code below throws Exception with message Undeserializable exception. But it should throw NameError instead.
Without sleep it works as expected.
distributed version: 1.20.0
# Undeserializable exception
from time import sleep
from distributed import Client, Variable
from dask import delayed
client = Client()
@delayed
def f():
fsdaf
return 5
future = client.compute(f())
future_var = Variable()
future_var.set(future)
sleep(0.1)
future_var.get().result()
This code below throws Exception with message Undeserializable exception. But it should throw NameError instead.
Without sleep it works as expected.
distributed version: 1.20.0