我知道目前 SLA 是通过一个简单的方法来实现任务的
sla=datetime.timedelta(hours=1)
在任务实例内,但我想知道是否有一种方法可以在气流中实现 DAG 级别 SLA,如果 dag 中的所有任务未在给定的时间增量内完成,则会发送警报?
最好的问候,阿里
python devops airflow
airflow ×1
devops ×1
python ×1