Блог

Граф Dask, который я создаю, имеет несколько выходных данных.

Мне было интересно, возможно ли визуализировать несколько выходных данных dask одновременно.

Когда я пытаюсь использовать dask.visualize(graph) . Где graph — кортеж или словарь узлов Dask. Похоже, что происходит сбой из-за создания пустого изображения.

Например:

 import dask

@dask.delayed
def op(x, y):
    return x   y

def graph():
    a = 1
    b = 2
    c = 3
    d = 4

    f = op(a, b)
    g = op(c, d)
    h = op(a, d)

    output1 = op(f, g)
    output2 = op(g, h)

    # works
    dask.visualize(output1, filename='output1.png')
    dask.visualize(output2, filename='output2.png')

    # empty small square box
    dask.visualize((output1, output2), filename='output1and2.png')
    # only outputs the name of the keys
    dask.visualize({'output1': output1, 'output2': output2}, filename='output1and2_.png')

graph()
  

dask.visualize Функция принимает множество аргументов, а не последовательность аргументов

Сделайте это

 dask.visualize(output1, output2, filename='output1and2.png')
  

Вместо этого

 dask.visualize((output1, output2), filename='output1and2.png')