Мой Dask .visualize() не отображает график должным образом. Код был взят из записной книжки http://github.com/dask/dask-tutorial/ 01_dask.delayed.ipynb.
Я установил graphviz с помощью pip и apt. Хотя график отображается, он не отображается полностью. Я запускаю код в 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
Я ожидал, что поля на изображении также будут заполнены данными. мой вывод кода





Это было преднамеренное изменение в Dask, потому что мы обнаружили, что метки ящиков представляют собой избыточные данные с именами вроде «inC# 1», что, поскольку оно исходит от функции с именем «inc», уже очевидно. Мы считаем, что нынешняя форма намного яснее. Действительно, изображение в качестве примера следует обновить, чтобы отразить изменение.
Возможно, вам будет интересно просмотреть рендеринг графиков в реальном времени в графическом представлении распределенного планировщика, где при наведении указателя появляется дополнительная информация о данном узле и его текущем состоянии.
Нет ни одной функции, но код для обхода графика, преобразования в graphviz, а затем интерпретации и рендеринга совсем не глубок, см. Модуль dask.base.visualize() и dask.dot.
Если бы мы хотели настроить вывод, на чем бы мы хотели сосредоточиться?