Дата выполнения использования воздушного потока: дата и время не определены

Question

Я хочу использовать время выполнения в Airflow и добавить к нему один день:

'{{(execution_date + timedelta(days=1)).strftime("%Y-%m-%d")}}'

Когда я выполняю это, я получаю

jinja2.exceptions.UndefinedError: 'timedelta' is undefined

Как я могу получить время выполненияплюс один день?

Answer 1

'{{(execution_date + macros.timedelta(days=1)).strftime("%Y-%m-%d")}}'

Использование макросов для передачи динамической информации в экземпляры задач во время выполнения.

Answer 2

Я нашел ответ здесь: https://diogoalexandrefranco.github.io/about-airflow-date-macros-ds-and-execution-date/

Вы можете использовать:

'{{(execution_date + macros.timedelta(days=1)).strftime("%Y-%m-%d")}}'

Объект макросов предоставляет общие функции и библиотеки python, такие как macros.datetime и macros.timedelta