Airflow 2.4.2中KubernetesPodOperator的on_failure_callback不触发求助

这大概率不是Airflow 2.4.2的原生Bug，更可能是配置或逻辑细节问题，以下是常见排查和解决方向：

• 回调函数的调用方式错误
  你当前的写法on_success_callback=send_success_notification()和on_failure_callback=send_failure_notification()会导致任务初始化时就直接执行回调函数，而非在任务成功/失败时触发。正确的写法应该传递函数引用（不带括号）：

  on_success_callback=send_success_notification,
  on_failure_callback=send_failure_notification
  

  之前成功时能收到通知，可能是因为初始化阶段就执行了send_success_notification()，但失败回调的触发逻辑依赖任务失败事件，提前执行自然不会在失败时响应。

• Pod退出码不符合失败判定
  Airflow对KubernetesPodOperator的失败判定完全依赖Pod的退出码。如果你的容器内脚本执行出错，但主动返回了退出码0，Airflow会判定任务成功，不会触发失败回调。可以通过Airflow UI查看任务日志，或直接查看Kubernetes Pod的退出状态，确认任务确实被标记为failed。

• 回调函数内部异常被吞
  如果send_failure_notification函数内部抛出异常，Airflow默认不会主动打印相关错误。可以在回调函数中添加日志输出或异常捕获，验证函数本身的可用性：

  def send_failure_notification(context):
      try:
          # 你的通知逻辑代码
          print("触发失败通知")
      except Exception as e:
          print(f"失败通知发送失败: {str(e)}")
          raise  # 抛出异常以便Airflow日志捕获
  

• 任务状态未进入failed
  如果任务被标记为up_for_retry（而非直接failed），失败回调不会触发。可以在Airflow UI的任务实例详情页查看实际状态，确认任务是否直接进入失败状态。

如果以上排查都无法解决问题，可以尝试升级到Airflow 2.4.3或更高版本——2.4.x系列后续版本修复了部分KubernetesPodOperator回调相关的边缘场景问题。

内容的提问来源于stack exchange，提问作者mato777