Понимание даты выполнения в Airflow

Question

Я запускаю DAG с воздушным потоком и хотел понять, как устанавливается дата выполнения. Это код, который я использую:

{{ execution_date.replace(day=1).strftime("%Y-%m-%d") }}

Это всегда возвращает первый день месяца. Мне нужна эта функциональность, но я просто хочу найти способ понять, что происходит.

Answer 1

Причина, по которой это всегда возвращает первое число месяца, заключается в том, что вы используете замену, чтобы обеспечить принудительное совпадение дня с первым.Просто удалите ".replace (day = 1)".

Answer 2

execute_date возвращает объект времени данных.Вы используете метод замены этого объекта, чтобы заменить «день» первым.Затем вывести его в строку с помощью метода format.