dask - 在 Dask 中将 Futures 作为参数传递

Question

Future将 a 传递给 Dask Delayed 函数以Future保持机智的最佳方法是什么？换句话说，我们如何确保函数将获得实际Future而不是它所代表的结果？

Answer 1

一般来说，语义是 dask.delayed 函数得到具体的结果，而不是 dask-y 的结果。如果没有一些技巧，今天就不容易支持。

话虽如此，我推荐以下技巧：

把你的未来放在一个变量中

import dask
from dask.distributed import Client, Variable
client = Client()

v = Variable()

@dask.delayed
def f(v):
    return v.get().result()

future = client.scatter(123)
f(future).compute()
# 123