如何无异常干净关闭容器化Dask LocalCluster及Client？

一、无需with语句的无异常关闭方法 #

异常根源是直接先关闭Cluster时，Client后台仍在尝试重连已终止的Scheduler，导致连接类报错。按以下步骤操作可避免：

# 1. 终止Client与Scheduler的所有连接，阻止后续重连尝试
client.cancel_connections()
# 2. 关闭Client并等待后台任务清理完成，超时时间可按需调整
client.close(timeout=10)
# 3. 最后关闭Cluster
cluster.close()

cancel_connections()会立即切断Client与集群的通信链路，close(timeout)确保Client的异步后台任务完全终止，避免残留线程引发报错。

二、手动调用上下文管理器方法（不用with） #

若想复用上下文管理器的安全清理逻辑，可直接调用__enter__和__exit__方法：

# 初始化后手动进入上下文
cluster.__enter__()
client.__enter__()

# 执行你的业务代码...

# 手动触发清理逻辑
try:
    # 先清理Client，参数代表无异常退出
    client.__exit__(None, None, None)
finally:
    # 确保Cluster最终被清理
    cluster.__exit__(None, None, None)

__exit__方法内部已封装了先Client后Cluster的安全关闭顺序，能自动处理连接断开和后台任务终止。

三、关闭顺序的明确结论 #

必须先关闭Client，再关闭Cluster。
先关Cluster会导致Scheduler直接终止，Client的后台协程会持续尝试重连，进而抛出连接类异常；先关Client则会主动断开所有连接、终止后台任务，此时再关闭Cluster不会有残留的连接请求，从根源避免报错。

内容的提问来源于stack exchange，提问作者jtlz2