dask - dask-distributed：如何取消使用 fire_and_forget 提交的任务？

Question

使用 fire_and_forget 提交任务图时，是否可以稍后（在新进程/客户端中）取消这些任务（例如通过键名）？这也会取消所有相关的任务，还是这些也像“fire_and_forget”一样？

Answer 1

是的，您可以使用键名创建新的未来

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)

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