Планировщик AirFlow — дата запуска
У меня есть DAG, который работает еженедельно каждый понедельник в 11 утра. Он работал 13 мая, был выключен 20 мая и снова включен 27 мая.
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?
Какими будут Дата исполнения и следующая_дата_выполнения в этом случае 3 июня?
Спасибо!
Ответы 1
Если вы посмотрите на все запущенные задачи текущего дня, вы увидите, что в Run отображается дата и время предыдущей запущенной задачи, определенной в schedule_interval. Started и Ended показывают текущую дату и время текущей задачи.
На следующей неделе (3 июня) вы увидите в Run эту дату `2019-05-27T11:00:00'
@brenoriba 3 июня, пока задача еще не запущена
В этом случае, просто чтобы убедиться в моем понимании: 3 июня он будет работать с <next_execution_date>, установленным на 3 июня, и <execution_date>, установленным на 27 мая, верно?
@бренориба Да. Ознакомьтесь с рекомендациями это, чтобы лучше понять
В таком случае 3 июня "следующая дата исполнения" будет 3 июня, а "дата исполнения" будет 27 мая? Спасибо!