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

Question

使用fire_and_forget提交任務圖時，以後（在新的進程/客戶端中）是否可以取消這些任務（例如按鍵名）？ 而且這也會取消所有的依賴任務，或者這些也是'fire_and_forget'-like？

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) 

這將取消以後，即使其他客戶的願望吧。