Python Dask .visualize（）不显示完整的图形

Question

我的Dask .visualize()没有正确显示图表。代码取自http://github.com/dask/dask-tutorial/ 01_dask.delayed.ipynb notebook。

我使用pip和apt安装了graphviz。即使显示图表，也未完全显示。我在jupyter Lab上运行代码

def inc(x):
    return x + 1

def double(x):
    return x + 2

def add(x, y):
    return x + y

data = [1, 2, 3, 4, 5]

output = []
for x in data:
    a = inc(x)
    b = double(x)
    c = add(a, b)
    output.append(c)

total = sum(output)

import dask

output = []
for x in data:
    a = dask.delayed(inc)(x)
    b = dask.delayed(double)(x)
    c = dask.delayed(add)(a, b)
    output.append(c)

total = dask.delayed(sum)(output)

total.visualize()  # see image to the right

我预计图像中的框也会填充数据。 my output of code

Answer 1

这是Dask中的故意改变，因为我们发现盒子的标签显示了名为“inc＃1”的冗余数据，因为它来自一个名为“inc”的函数已经很明显了。我们发现目前的形式更加清晰。实际上，应该更新示例图像以反映变化。

您可能会发现在分布式调度程序的图形视图中查看图形的实时呈现很有意思，其中指针悬停提供有关给定节点及其当前状态的更多信息。