气流中的 DAG 级别服务级别协议

Ali*_*Ali 5 python devops airflow

我知道目前 SLA 是通过一个简单的方法来实现任务的

sla=datetime.timedelta(hours=1)

在任务实例内,但我想知道是否有一种方法可以在气流中实现 DAG 级别 SLA,如果 dag 中的所有任务未在给定的时间增量内完成,则会发送警报?

最好的问候,阿里