airflow sla_miss_callback不触发自定义函数

Question

Apache Airflow 1.10.7我希望在sla未命中任务时触发自定义函数。我在dag初始化期间设置此属性

def sla_callback_function():
# custom logic
dag=DAG('sla_test', default_args=default_args, schedule_interval='00 10 * * *', sla_miss_callback=sla_callback_function)

SLA时间是在任务级别上设置的(只有一个任务(。我收到了SLA未命中的电子邮件，并在UI中看到SLA未命中，但我没有看到自定义功能被触发。

Answer 1

我知道现在回答这个问题已经很晚了，但如果你还在寻找答案，这可能会有所帮助。您的自定义函数定义应该如下所示：

def sla_callback_function(*args):
# custom logic
dag=DAG('sla_test', default_args=default_args, schedule_interval='0 10 * * *', sla_miss_callback=sla_callback_function)

Answer 2

尝试为函数传递参数sla_miss_callback=sla_callback_function((