Планировщик AirFlow - дата запуска

Question

У меня есть DAG, которая запускается еженедельно каждый понедельник в 11:00.Он работал 13/05, был выключен 20/05 и снова включен 27.05.

dag = DAG(
    'my_dag',
    description='my_desc',
    default_args=args,
    schedule_interval='0 11 * * 1',
    max_active_runs=1,
    catchup=False)

У меня вопрос: 27/05 DAG запускался, но "дата запуска" былаустановите 20/05, и я не знаю почему.Это потому, что он был выключен 20/05 и DAG получил «последнюю запланированную дату»?В этом случае на следующей неделе (3 июня) он будет работать с «датой выполнения», установленной на 27/05 или 03/06?

Что будет execute_date и next_execution_date в данном случае 3 июня?

Спасибо!

Answer 1

Если вы посмотрите на все запущенные задачи текущего dag, вы увидите, что на Run отображается дата и время предыдущего запущенного задания, определенного в schedule_interval. Started и Ended показывают текущую дату и время текущей задачи. На следующей неделе (3 июня) вы увидите в Run эту дату `2019-05-27T11: 00: 00 '