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

Question

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

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()

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

Answer 1

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

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