Sob algumas condições, quero fazer uma tarefa de aipo falhar nessa tarefa. Eu tentei o seguinte:

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

No entanto, a tarefa ainda relata ter sido bem-sucedida:

Task sim.tasks.run_simulation [9235e3a7-c6d2-4219-bbc7-acf65c816e65] conseguiu 1.17847704887s: False

Parece que o estado só pode ser modificado enquanto a tarefa está em execução e depois de concluída - o aipo altera o estado para o que julgar ser o resultado (consulteessa questã). Existe alguma maneira, sem falhar na tarefa levantando uma exceção, para fazer o aipo retornar que a tarefa falhou?