查看 Dask 任务图
View Dask Task Graph
我正在使用 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)
在计算完成后，有什么方法可以 view/visualize 此范例中的 DAG？
documentation 似乎非常适合 Dask 延迟范式。如果重要的话，这是针对分布式集群的。
截至 2019-06-21，不是真的，不是。
您可以在仪表板的 /graph 页面上实时查看它，但目前没有任何方便的代码来呈现图形的静态图像。我会说这在范围内，但不是当前维护者今天正在认真考虑的事情。
我正在使用 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)
在计算完成后，有什么方法可以 view/visualize 此范例中的 DAG？
documentation 似乎非常适合 Dask 延迟范式。如果重要的话，这是针对分布式集群的。
截至 2019-06-21，不是真的，不是。
您可以在仪表板的 /graph 页面上实时查看它，但目前没有任何方便的代码来呈现图形的静态图像。我会说这在范围内，但不是当前维护者今天正在认真考虑的事情。