我是 Airflow 新手,正在尝试在我的 DAG 中实现 sla miss 功能
default_args = {
'owner': 'airflow',
'depends_on_past': False,
'start_date': datetime(2017,07,24),
'email': ['jspsai@gmail.com'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 5,
'retry_delay': timedelta(minutes=5),
'sla':timedelta(seconds=30),
'pool':'demo',
'queue':'slaq',
'run_as_user':'ec2-user'
}
Run Code Online (Sandbox Code Playgroud)
但这个 SLA 没有应用,我无法弄清楚问题是什么
我也在任务级别给出了 SLA,但运气不佳。
任何帮助是极大的赞赏。
谢谢
airflow ×1