在创建 dask 任务图时,如何使用命名参数创建调用?例如:
def foo (x=1, y=2):
...
graph = { 'z': foo, "y=100" }
这行不通。
您可以使用dask.delayed生成自定义图表。
def foo(x=1, y=2):
...
x = delayed(foo)(x=1, y=2)
这通常是最好的方法。它是万无一失的,简单的,以及 dask 开发人员在内部使用新代码所做的事情。
如果您真的想手动制作图表,可以使用位置参数
graph = {'z': (foo, 1, 100)}
您也可以使用应用
from dask.compatibility import apply
graph = {'z': (apply, foo, [], {'y': 100})}