Airflow SLA未实现

Question

我刚接触Airflow，正在尝试在我的DAG中实现sla未命中功能

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'
}

但是这个sla并没有被应用，我不知道问题出在哪里

我还给出了任务级别的sla，但没有成功。

任何帮助都是非常感谢的。

谢谢

Answer 1

我不知道这是否能解决您的问题，但是关于Airflow中的sla的一件事是，它们只适用于计划的任务。如果您手动运行它们，则不会考虑sla。