如果我有一个distributed.Client
实例,我可以用它来关闭远程集群吗?即杀死所有工人并关闭调度程序?
如果使用Client
实例无法完成除了手动查杀每个远程进程之外还有其他方法吗?
没有专门针对此的客户端功能。
调度程序有一个close()
方法,你可以使用run_on_scheduler
调用它
c.run_on_scheduler(lambda dask_scheduler=None:
dask_scheduler.close() & sys.exit(0))
这将告诉工作人员断开连接并关闭,并在终止进程之前关闭所有连接。请注意,这会在客户端引发错误,因为连接在没有回复的情况下中断。可能有更优雅的方式。
请注意,执行此操作的正确方法可能是与其中一个部署群集管理器进行交互。例如,LocalCluster
有一个面向用户的close()
方法,你可以直接调用它。