气流sla_miss_callback函数不会触发，也不会显示在dag详细信息页面中

Question

我想通过我在dag初始化期间调用的自定义回调函数发送警报，如下所示-

dag = DAG('tutorial', default_args=default_args, schedule_interval=timedelta(days=1), sla_miss_callback=my_sla_miss_cb_func)

我的def签名如下-

def my_sla_miss_cb_func():
        ...custom_logic....

我具有要监视的任务的sla属性，当我给email_on_failure = True时看到SLA MISS电子邮件，但my_sla_miss_cb_func函数没有被调用/触发。

此外，sla_miss_callback属性也不会在气流UI的Details页面中显示。

我正在使用气流1.7.1.3

Answer 1

您能解决问题吗？