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では、あなたが

future.cancel(force=True) 

force=Trueキーワードを使用することができますこれは、他のクライアントがそれを望む場合でも、将来的にキャンセルされます。