Предотвратить мгновенный запуск отключенной группы DAG при ее включении - PullRequest
0 голосов
/ 17 июня 2020

В Airflow 1.10.10, когда отключенный DAG активируется нажатием кнопки для изменения его состояния с Off на On, DAG всегда будет запускаться один раз перед следующим запланированным временем выполнения.

enter image description here

Можно ли включить группу DAG, но не выполнять ее первый запуск до следующего запланированного запуска?

В настоящее время мне нужно быстро остановить запуск DAG после того, как я переключу его состояние на On.

Ответы [ 2 ]

0 голосов
/ 19 июня 2020

Если это ежедневная задача - установите дату начала, как показано ниже: Это предотвратит запуск вашей 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) 
}
0 голосов
/ 18 июня 2020

Вы должны установить start_date (который является datetime) равным значению после now.

Согласно docs

  • первый DAG Run создается на основе минимальной start_date для задач в вашей DAG.
  • Последующие DAG Run создаются процессом планировщика на основе вашего DAG schedule_interval, последовательно.
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...