dask - Dask Client 检测本地默认集群已经在运行

Question

from dask.distributed import Client

Client()
Client(do_not_spawn_new_if_default_address_in_use=True)  # should not spawn a new default cluster

这有可能以某种方式做到吗？

标签： daskdask-distributed

Answer 1

非公共函数distributed.client._get_global_client()将返回当前客户端（如果存在），或者None

client = _get_global_client() or Client()

由于它是内部的，API 可能会更改，恕不另行通知。