Dask：从 Python 设置多处理方法

Question

有没有办法从 Python 设置多处理方法？我在 Dask.distributed 的 Client() API 文档中没有看到指示如何设置此 属性.

的方法

更新：

比如有没有：

client = Client(multiprocessing='fork')

或

client = Client(multiprocessing='spawn')

?

Answer 1

不幸的是，多处理上下文方法是在 dask.distributed 的导入时设置的。如果您想从 Python 设置它，您可以在导入 dask 之后设置配置值，但在导入 dask.distributed.

之前

import dask
dask.config.set({'distributed.worker.multiprocessing-method': 'spawn'})

from dask.distributed import Client

然而，在您的配置文件中设置它可能更可靠。有关设置配置值的各种方法，请参阅 configuration documentation。

注意：这是使用截至 dask.__version__ == '0.18.0'

的配置