шагов (сегодня 7 января 2020 года):
1) Добавьте в dir 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)
Обратите внимание на флаг догоняющего типа, запрещающий планировать поток воздуха при истечении срока действия. даты.
2) Запустить fre sh Экземпляр воздушного потока
3) Включить знак в UI
4) Выполнение:
Я действительно не понимаю, почему эти задержки на истекшие даты (5 января и 6 января) планируются и выполняются, если я использую флаг подтягивания и развертывания в январе 7. Любой совет? Спасибо!
Обновление: без флага догонялки я получил:
Итак:
1) догонять флаг принимается во внимание
2) похоже, есть ошибка или он плохо настроен, потому что, когда он установлен в False, воздушный поток все еще планирует на истекшие даты (5 января и 6 января).