Шаги (сегодня 7 января 2020 года):
1) Поместите следующий тег в каталог Airflow:
from datetime import datetime
from airflow import DAG
from airflow.operators.bash_operator import BashOperator
dag = DAG(dag_id='example_dag', start_date=datetime(2020, 1, 1), catchup=False)
t1 = BashOperator(task_id='bash_task', bash_command='echo Hola!', dag=dag)
Обратите внимание на флаг наверстывания, препятствующий расписанию Airflow в даты с истекшим сроком действия.
2) Запустите свежий экземпляр Airflow
3) Включите даг в UI
4) Исполнение:
Я действительно не понимаю, почему эти даги с истекшими датами (5 января и 6 января) планируются и выполняются, если я использую флаг наверстывания и развертываю 7 января. Какие-нибудь советы? Спасибо!
Обновление: без флага наверстывания я получил:
So:
1) учитывается флаг наверстывания
2) кажется, что в нем есть ошибка или он плохо настроен, потому что, когда он установлен на False, Airflow все еще выполняет планирование на даты с истекшим сроком (5 января и 6 января).
schedule_interval
. и по умолчанию schedule_interval составляет один день. airflow.apache.org/docs/stable/scheduler.html. - person Emma   schedule 08.01.2020