Реализация пропуска SLA Airflow

Я новичок в Airflow и пытаюсь реализовать функцию промаха sla в моем DAG

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2017,07,24),
    'email': ['[email protected]'],
    '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 на уровне задач, но безуспешно.

Любая помощь приветствуется.

Спасибо


airflow
person user3334761    schedule 25.07.2017    source источник

Ответы (1)


arrow_upward
3
arrow_downward

Я не знаю, решит ли это вашу проблему, но одна особенность sla в Airflow заключается в том, что они работают только с запланированной задачей. Если вы запустите их вручную, SLA не рассматриваются.

person Andrea Maruccia    schedule 16.03.2018
comment
Не могли бы вы поделиться источником этой информации? Ничего подобного в документации найти не удалось, и моя реализация не сработала. - person mustafagok; 15.05.2019
comment
не знаю, так ли это сейчас, но тогда я провел целый день, тестируя это. просто попробуй и проверь. - person Andrea Maruccia; 16.05.2019
comment
По крайней мере, ваш комментарий решил частичную проблему, с которой я столкнулся. - person mad_; 19.09.2020