Jak sprawić, aby zadanie selera nie powiodło się w ramach zadania?

Question

Pod pewnymi warunkami chcę sprawić, aby zadanie selerowe nie powiodło się w ramach tego zadania. Próbowałem następujące:

from celery.task import task 
from celery import states 

@task() 
def run_simulation(): 
    if some_condition: 
     run_simulation.update_state(state=states.FAILURE) 
     return False 

Jednak zadanie nadal zgłasza się udało:

sim.tasks.run_simulation Task [9235e3a7-c6d2-4219-bbc7-acf65c816e65] udało się 1.17847704887s : Fałsz

wydaje się, że państwo może być modyfikowana tylko wtedy, gdy zadanie jest uruchomiony, a po jego zakończeniu - seler zmienia stan na cokolwiek uzna to wynik (patrz this question). Czy jest jakiś sposób, bez zaniedbania zadania przez podniesienie wyjątku, aby zwrócić selerowi, że zadanie się nie powiodło?

Answer 1

Otrzymałem interesting reply na to pytanie od Ask Solem, gdzie proponuje pomocnika "after_return", aby rozwiązać problem. To może być interesująca opcja na przyszłość.

W międzyczasie I rozwiązać ten problem, po prostu zwracając ciąg „porażka” od zadania, gdy chcę, aby go zawieść, a następnie sprawdzenie, że w następujący sposób:

result = AsyncResult(task_id) 
if result.state == 'FAILURE' or (result.state == 'SUCCESS' and result.get() == 'FAILURE'): 
    # Failure processing task 

Answer 2

lepszy sposób to zrobić jest aktualizacja stanu zadania jako FAILURE a następnie podnieść wyjątek Ignore, ponieważ zwraca żadnej wartości rejestruje zadanie jako udane, przykład:

from celery import Celery, states 
from celery.exceptions import Ignore 

app = Celery('tasks', broker='amqp://guest@localhost//') 

@app.task(bind=True) 
def run_simulation(self): 
    if some_condition: 
     # manually update the task state 
     self.update_state(
      state = states.FAILURE, 
      meta = 'REASON FOR FAILURE' 
     ) 

     # ignore the task so no other state is recorded 
     raise Ignore()