1
fire_and_forget을 사용하여 작업 그래프를 제출할 때 나중에 (새 프로세스/클라이언트에서) 해당 작업을 (예 : 키 이름으로) 취소 할 수 있습니까? 또한 모든 종속 작업을 취소 할 것인가, 아니면 이것 또한 'fire_and_forget'과 같은 것입니까?dask-distributed : fire_and_forget으로 제출 된 작업을 취소하는 방법?
A
답변
0
예, 당신도 여러 클라이언트의 얼굴에 취소를 강제 키 이름
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)
를 사용할 수 있습니다.
감사합니다. 얼마나 쉬울 수 있습니까? :-) 그리고 제 질문의 두 번째 부분은 어떻습니까? fire_and_forget을 사용하여 긴 dsk를 제출하고 마지막 작업을 취소하면 나머지 그래프도 취소됩니까? 또는 모든 개별 작업을 개별적으로 취소해야합니까? –
이 항목을 https://github.com/dask/distributed/pull/1408에 추가했습니다. – MRocklin