Definir un SLA
Has implementado con éxito varios flujos de trabajo de Airflow en producción, pero ahora mismo no tienes forma de determinar si un flujo tarda demasiado en ejecutarse. Tras consultarlo con tu responsable y tu equipo, decides implementar un SLA a nivel de DAG en un flujo de prueba.
Todas las bibliotecas de Airflow necesarias ya se han importado por ti.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Importa el objeto
timedelta. - Define un
slade 30 minutos. - Añade el SLA al DAG.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el 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)