查看 Dask 任务图

Question

我正在使用 Dask submit 和 gather 范式来做类似的事情：

data_future = client.scatter(data, broadcast=True)
futures = []
for i in range(10):
    futures.append(dask.submit(some_func, i, data_future))
results = dask_client.gather(futures)

计算完成后，是否有某种方法可以在此范例中查看/可视化 DAG？

该文档似乎非常适合 Dask 延迟范例。万一重要，这是针对分布式集群的。

Answer 1

截至 2019-06-21，不是真的，没有。

您可以在仪表板的/graph页面上实时查看它，但目前没有任何方便的代码来呈现图形的静态图像。 我想说这是在范围内，但不是当前维护者今天正在认真思考的事情。