黄昏计算（以捕获错误），但将结果保留在工作程序上

Question

我想定义一组动作，然后在达人的工作程序上运行它们，并捕获可能出现的任何错误，而不必调用计算并将结果带给客户端。

例如，如果我在对象列上执行astype（int），这应该给我一个错误。当我使用client.persist时，这不会给我带来错误。

column = df['string column'].astype(int)
client.persist(column)

但是，client.compute确实抛出此错误：

column = df['string column'].astype(int)
client.compute(column)
# ValueError ... Traceback (most recent call last)

是否有一种方法可以像在计算中一样立即获取错误，但不强制Dask将结果返回给客户端？

Answer 1

column = column.persist()
dask.distributd.wait(column)