KubernetesPodOperator on_failure_callback在气流2.4.2上不起作用

Question

当使用最新的Airflow版本(2.4.2)时，KubernetesPodOperator任务不会触发on_failure_callback。on_success_callback工作得很好。

对于每个KubernetesPodOperator任务，我设置on_success_callback=send_success_notification()和on_failure_callback=send_failure_notification()。

如果任务成功，则发送通知。然而，在失败的情况下，on_failure_callback不会被触发。这是最新版本的bug吗?

Answer 1

我知道这是一个迟来的答案，但是在例子中有一个错误或打字错误:

…我设置了on_success_callback=send_success_notification()和on_failure_callback=send_failure_notification()

send_success_notification()和send_failure_notification()都应该是对函数的引用，而不是函数调用。我的意思是你需要从末尾去掉括号()，像:

on_success_callback=send_success_notification和on_failure_callback=send_failure_notification