Crear una cadena de producción nº 2

Continuando con tu último flujo de trabajo, te gustaría añadir alguna funcionalidad adicional, concretamente añadir algunos SLAs al código y modificar los componentes del sensor.

Consulta el código fuente de DAG para determinar si es necesario añadir algo más. El diccionario default_args se ha definido para ti, aunque puede requerir más modificaciones.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Instrucciones del ejercicio

Añade un sla de 90 minutos al DAG utilizando la función timedelta().
Actualiza el objeto FileSensor para que busque archivos cada 45 segundos utilizando el parámetro poke_interval.
Modifica el python_task para enviar variables Airflow a la llamada. Ten en cuenta que la llamada está configurada para aceptar las variables mediante el argumento provide_context.

Ejercicio interactivo práctico

Pon en práctica la teoría con uno de nuestros ejercicios interactivos

Empezar ejercicio