查看 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？

documentation 似乎非常适合 Dask 延迟范例。万一这很重要，这适用于分布式集群。

Answer 1

截至 2019 年 6 月 21 日，不是真的，不是。

您可以在仪表板的/graph 页面上实时查看它，但目前没有任何方便的代码来呈现图表的静态图像。我会说这是在范围内，但不是当前维护人员今天非常努力考虑的事情。