Посмотреть график задач 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 в этой парадигме после завершения вычислений?

Документация , кажется, хорошо подходит для парадигмы отсрочки Dask.В случае, если это имеет значение, это для распределенного кластера.

Answer 1

По состоянию на 2019-06-21, не совсем, нет.

Вы можете просмотреть его вживую на странице /graph панели инструментов, но сегодня нет удобного кода для визуализации статического изображения графика.Я бы сказал, что это входит в сферу, но не то, о чем современные разработчики очень серьезно думают сегодня.