Dask не показывает индикатор выполнения

Когда я запускаю это, я вижу только индикатор выполнения, а я нет.

from math import factorial

from dask.diagnostics import ProgressBar
from dask.distributed import Client


def dask_progress():
    client = Client()
    print(client)
    m = client.map(factorial, range(10))
    with ProgressBar():
        print(client.gather(m))


if __name__ == "__main__":
    dask_progress()

Это результат.

<Client: 'tcp://127.0.0.1:65468' processes=4 threads=8, memory=17.18 GB>
[1, 1, 2, 6, 24, 120, 720, 5040, 40320, 362880]

Я вижу то же самое с этим

from math import factorial

from dask.distributed import Client, progress


def dask_progress():
    client = Client()
    print(client)
    m = client.map(factorial, range(10))
    progress(m)
    print(client.gather(m))


if __name__ == "__main__":
    dask_progress()

Что мне нужно сделать, чтобы увидеть индикатор выполнения?


person W.P. McNeill    schedule 03.08.2020    source источник


Ответы (1)


Для разных планировщиков существуют разные индикаторы выполнения.

См. https://docs.dask.org/en/latest/understanding-performance.html

person MRocklin    schedule 08.08.2020