셀러리 : 중단 또는

Question

가 나는 레디 스 브로커와 백엔드와 다음 설정을 사용하여 화음의 모든 작업을 취소 :

chord([A, A, A, ...])(B)

• 작업 A는 몇 가지 검사를 수행합니다. AbortableTask을 기본으로 사용하고 task.is_aborted() 플래그를 정기적으로 확인합니다.
• 태스크 B가 계산

사용자는 A가 작업을 중단 할 가능성이 결과에 대해 사용자에게 통지한다. 아쉽게도 모든 작업 A 인스턴스에서 AbortableAsyncResult(task_a_id).abort()을 호출하면 활성 인스턴스 만 중단됩니다. 아직 작업자가받지 못한 작업의 상태는 ABORTED으로 변경되지만 여전히 처리되며 is_aborted() 플래그는 False를 반환합니다.

당연히 대신에 보류중인 작업을 수행 할 수도 있지만 문제는 그 코드 바디 (작업 B)가 더 이상 실행되지 않는다는 것입니다.

보류중인 실행중인 작업 A 인스턴스를 중지하고 B 작업을 계속 실행하려면 어떻게해야합니까?

Answer 1

작업 자체에 코드를 지정하는 대신 A 작업을 보는 코드 작업을 고려하는 것이 좋습니다. 이것이 의미하는 바는, 화음에는 실행중인 작업 (A)을 가끔씩 점검하여 수행 여부를 확인하는 작업이 포함되어 있다는 것입니다. 그들 모두가 성공적으로 작업 B로 체인과 함께 화음을 반환하면 모든 인스턴스의 ID의 목록을 얻을 그들을 막을 수 있습니다.

Answer 2

지금 당신은 당신이 원하는 무엇이든 할 수

for taks in my_chord.parent.subtasks: 
    print(task.id) 

를 사용하여,이 간단한 코드 이제

from celery import chord 

my_chord = chord(a.si() for i in range(300))(b.si()) 

당신은 하위 목록 my_chord 인스턴스 (a 작업의 모든 instaces)를 얻을 수를 고려 그 작업 instures 함께 할. 예를 들어 현재 상태에 관계없이 모두 취소 할 수 있습니다.

기본적으로 보류중인 작업 만 종료됩니다. 그러나 terminate=True을 전달하면 실행중인 작업도 종료됩니다.

또한 코드의 콜백 함수는 모든 하위 작업이 성공적으로 실행 된 후에 호출됩니다. 코드의 하위 작업을 취소하기 때문에 콜백 기능이 호출되지 않고 코드 작업이 실패합니다. 콜백 작업을 다시 시도해야합니다.