python - 在故意失败的回调中将任务标记为成功

Question

在 Airflow 2.3.4 中，我有一个任务我故意失败，当它失败时我想将其标记为成功 在回调中，但下面不起作用。，

def intentional_failure():
     raise AirflowException("this is a dummy failure")

def handle_failure(context):
     context['task_instance'].state = State.SUCCESS

dummy_failure = PythonOperator(task_id="intentional_failure", python_callable=intentional_failure, on_failure_callback=handle_failure)

如何以编程方式将故意失败的任务标记为成功？

Answer 1

事实证明这是一个方法调用而不是一个属性。所以我们需要在on_failure_callback中设置context['ti'].set_state(State.SUCCESS)。