Предотвратить немедленный запуск отключенной группы DAG при включении
В Airflow 1.10.10, когда отключенный DAG включается нажатием кнопки, чтобы изменить его состояние с Off
к On
, группа доступности базы данных всегда будет запускаться один раз до следующего запланированного времени выполнения.
Можно ли включить группу DAG, но не запускать ее первый раз до следующего запланированного запуска?
В настоящее время мне нужно быстро остановить запуск DAG после того, как я переключу его состояние на On
.
2 ответа
Вы должны установить start_date (который является datetime
) значение после now
.
Согласно документам
- первый запуск DAG создается на основе минимальной start_date для задач в вашей DAG.
- Последующие запуски DAG создаются процессом планировщика последовательно на основе schedule_interval вашей группы DAG.
Если это ежедневная задача - установите дату начала, как показано ниже: Это предотвратит запуск DAG сразу после включения.
default_args = {
'start_date': airflow.utils.dates.days_ago(1)
}
If it is a monthly task - set start date as below :
default_args = {
'start_date': airflow.utils.dates.days_ago(30)
}