Definir el orden de ejecución del pipeline
Después de construir tu DAG, toca definir el orden de ejecución de las tareas del DAG.
En el ejercicio anterior, configuraste la primera tarea para comprobar la API. Todas las demás tareas del pipeline ya están preparadas para ti.
Debes seguir el orden de tareas del siguiente diagrama.
Este ejercicio forma parte del curso
Diseño de canalizaciones de predicción para producción
Instrucciones del ejercicio
- Configura las tareas del pipeline de comprobación de la API y de comprobación del estado.
- Configura las tareas del pipeline de validación de datos.
- Configura las tareas del pipeline de predicción.
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# Set the API check pipeline tasks
____ >> ____ >> [data_refresh, no_updates]
data_refresh >> [data_validation, data_failure]
# Set the data validation pipeline tasks
data_validation >> check_validation >> [____, ____]
# Set the forecast pipeline tasks
data_valid >> ____ >> ____
print(f"DAG '{dag.dag_id}' ready with {len(dag.tasks)} tasks")