Definición de una SLA
Has implementado con éxito varios flujos de trabajo Airflow en producción, pero actualmente no tienes ningún método para determinar si un flujo de trabajo tarda demasiado en ejecutarse. Tras consultarlo con tu jefe y tu equipo, decides implantar un SLA en el nivel DAG en un flujo de trabajo de prueba.
Se han importado para ti todas las bibliotecas Airflow adecuadas.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones de ejercicio
- Importa el objeto timedelta.
- Define un
slade 30 minutos. - Añade la SLA a la DAG.
Ejercicio interactivo práctico
Pruebe este ejercicio completando este código de muestra.
# Import the timedelta object
____
# Create the dictionary entry
default_args = {
'start_date': datetime(2024, 1, 20),
'____': ____
}
# Add to the DAG
test_dag = DAG('test_workflow', default_args=____, schedule_interval=None)