开始dask LocalCluster时

from dask.distributed import Client
client = Client()

并在中断jupyter内核并重新运行单元

时间戳

首页 > 解决方案 > dask：关闭悬空流

开始dask LocalCluster时

from dask.distributed import Client
client = Client()

并在中断jupyter内核并重新运行单元

dask - dask：关闭悬空流

开始dask LocalCluster时

from dask.distributed import Client
client = Client()

并在中断jupyter内核并重新运行单元

问题描述

开始dask LocalCluster时

from dask.distributed import Client
client = Client()

并在中断jupyter内核并重新运行单元 dask后一次又一次地显示以下警告。

distributed.comm.tcp - WARNING - Closing dangling stream in <TCP  local=tcp://127.0.0.1:49408 remote=tcp://127.0.0.1:37487>

重新启动内核没有帮助。

如何重新LocalCluster启动从头开始？

如果您以某种意想不到的方式杀死 Dask 集群，那么是的，您可能会收到这样的警告。他们没问题，不应该严重影响事情。

如果你想干净地关闭东西，你可以调用 close 方法。

cluster.close()

标签： dask

解决方案

如果您以某种意想不到的方式杀死 Dask 集群，那么是的，您可能会收到这样的警告。他们没问题，不应该严重影响事情。

如果你想干净地关闭东西，你可以调用 close 方法。

cluster.close()

推荐阅读