问dask-distributed:如何取消fire_and_forget提交的任务？
EN

Stack Overflow用户

提问于 2017-09-18 19:57:20

回答 1查看 740关注 0票数 2

当使用fire_and_forget提交任务图时，是否可以稍后(在新的流程/客户端中)取消这些任务(例如，通过键名称)？这是否也会取消所有依赖的任务，或者这些也是类似于“火和忘记”的？

发布于 2017-09-18 21:15:59

可以，您可以使用密钥名称创建新的未来

from dask.distributed import Future

future = Future(key_name, my_client)
future.cancel()

即使面对多个客户端，强制取消似乎也是合理的(fire-and-forget被认为是它自己的客户端)。在这里实现：https://github.com/dask/distributed/pull/1408。在1.18.3以上的版本中，您将能够使用force=True关键字

future.cancel(force=True)

这将取消未来，即使其他客户想要它。

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/46278692

复制

相似问题

问dask-distributed:如何取消fire_and_forget提交的任务？EN