如何检查是否有一个已经在运行的 dask 调度程序？

Question

我想从具有特定数量的工作人员的 python 启动本地集群，然后将客户端连接到它。

cluster = LocalCluster(n_workers=8, ip='127.0.0.1')
client = Client(cluster)

但在此之前，我想检查是否存在现有的本地集群，例如由 dask-scheduler 命令启动。有没有办法做到这一点 ？

Answer 1

没有标准约定来检查您的机器上是否存在调度程序。您能做的最好的事情就是尝试短暂的超时。默认端口为 8786

from dask.distributed import Client, TimeoutError

try:
    client = Client('tcp://localhost:8786', timeout='2s')
except TimeoutError:
    pass