Я изо всех сил пытаюсь понять, как заставить dask отложить работу над конкретным рабочим процессом, который включает в себя создание словаря. Идея здесь в том, что func1, func2, func3 могут работать независимо друг от друга в одно и то же время, и...

Я пытаюсь использовать dask.delayed для вычисления большой матрицы для использования в последующих вычислениях. Я всегда запускаю код только на одном локальном компьютере. Когда я использую dask планировщик для одной машины, он работает...

По умолчанию функция graph.visualize () не отображает метки задач. Есть ли способ добавить их вручную с помощью graph = dask.delayed()(tasks) ? Мне нужны ярлыки, чтобы показать основную бизнес-логику (какие таблицы с какими соединены и т. Д.).

dask.distributed сохраняет данные в памяти на рабочих процессах до тех пор, пока эти данные больше не будут нужны. (Спасибо @MRocklin!) Хотя этот процесс эффективен с точки зрения использования сети, он все же приведет к частому сбору и...

У меня следующая установка: # etl.py from dask.distributed import Client import dask from tasks import task1, task2, task3 def runall(**kwargs): print("done") def etl(): client = Client() tasks = {} tasks['task1'] =...