Dask Multiprocessing

Question

Я пытаюсь запустить следующий код. Он работает, если выполняется в оболочке, но падает, если выполняется как макрос (py macro.py). Пожалуйста, не могли бы вы сказать мне, что не так. Спасибо

import os
import sys
import dask
from dask.distributed import Client

def inc(x):
    return x + 1

def add(x, y):
    return x + y

client = Client(n_workers=2, threads_per_worker=2, memory_limit='1GB')

a = client.submit(inc, 10)
b = client.submit(inc, 20)
print(a.result())
print(b.result())

Answer 1

Это проблема с запуском скриптов, которые создают процессы. Вам необходимо создать объект Client в блоке if __name__ == "__main__":

. См. Ответ в , где разместить freeze_support () в скрипте Python? для получения дополнительной информации.