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

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

Answer 1

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

client = _get_global_client() or Client()

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