要解决"airflow sla_miss_callback不会触发自定义函数"的问题,可以按照以下步骤进行操作:
def custom_sla_miss_callback(context):
# 在这里执行自定义的逻辑代码
# 例如,发送通知或记录日志
print(f"SLA miss for task: {context['task_instance'].task_id}")
airflow.cfg
),然后将以下行添加到文件的末尾:[sla]
sla_miss_callback = your_module.custom_sla_miss_callback
确保将your_module
替换为包含你自定义函数的模块名。
现在,当任务的SLA未达标时,自定义的SLA Miss Callback函数将被调用,并执行自定义的逻辑代码。