#python #cron #airflow
#python #cron #воздушный поток
Вопрос:
У меня есть задание воздушного потока с ежедневным расписанием. Он работал совершенно нормально каждый день, до вчерашнего дня, когда я вручную запустил dag через несколько часов после запланированного запуска. На следующий день после этого (сегодня) задача не была выполнена).
start date - 31.08.2020 03:00 @daily -> scheduled, all good
01.09.2020 03:00 -> scheduled, all good
01.09.2020 06:00 -> manual trigger
02.09.2020 03:00 -> task was not executed!
Я ничего не изменил в коде / конфигурации, поэтому подозреваю, что вчерашний ручной запуск привел к тому, что сегодня dag не выполнялся по расписанию. Может ли быть другая причина?
default_args = {
'owner': 'raydex',
'depends_on_past': False,
'start_date': datetime(2020,5,31),
}
with DAG('task', default_args=default_args, schedule_interval='0 3 * * *', catchup=False) as dag:
Кто-нибудь знает, что именно вызвало это? Как я могу предотвратить повторение этой проблемы? Мне нужно было снова запустить его вручную из-за того, что задание не было запланировано. Я хочу, чтобы это было автоматически запланировано еще раз, начиная с завтрашнего дня (03:00).
В пользовательском интерфейсе статус «ВКЛЮЧЕН» и был «ВКЛЮЧЕН».
Комментарии:
1. У меня такая же проблема, установка catchup = True — это моя текущая работа, надеюсь, кто-нибудь сможет это объяснить.
Ответ №1:
Может быть, вы используете версию 2? Похоже, что это потенциальная ошибка или, по крайней мере, незарегистрированное изменение поведения для версии 2. Вы можете узнать больше здесь.