Quiero usar el tiempo de ejecución en Airflow y agregarle un día:

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

Cuando ejecuto esto me sale

jinja2.exceptions.UndefinedError: 'timedelta' is undefined

¿Cómo puedo obtener el tiempo de ejecución más un día?

3
Juta 4 feb. 2019 a las 16:40

2 respuestas

La mejor respuesta

Encontré la respuesta aquí: https: // diogoalexandrefranco .github.io / about-airflow-date-macros-ds-and-execution-date /

Puede utilizar:

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

El objeto macros expone funciones y bibliotecas comunes de python como macros.datetime y macros.timedelta

2
Juta 4 feb. 2019 a las 13:41
'{{(execution_date + macros.timedelta(days=1)).strftime("%Y-%m-%d")}}'

Use macros para pasar información dinámica a instancias de tareas en tiempo de ejecución.

0
Mohammed Sherif KK 6 feb. 2019 a las 04:28