如何确定 dask worker 是否空闲？

Question

我正在使用 dask 分布式。我有一个在 AWS 上运行的 dask 集群。如果工人空闲，我想关闭他们。我如何确定 dask 工作人员是否空闲？我可以访问客户端

    from xxxxxx.distributed.ecscluster import EcsCluster
    from dask.distributed import Client
    
    cpu_cluster = EcsCluster(workers=1)
    client = Client(cpu_cluster)

Answer 1

您可以使用dask-labextension 访问集群可视化并识别空闲的工作人员。

您还可以插入 Dask adaptive scaling API，这些 API 旨在降低空闲节点的速度。