Ramificación con HITLBranchOperator
Un pipeline de enrutamiento de quejas usa HITLBranchOperator para que una persona elija qué equipo gestiona cada ticket. El Dag ya está desplegado: lanza una ejecución, elige una rama y observa cómo Airflow se encarga del resto.
Sigue estos pasos:
- En la vista Dags, activa
complaint_routery lanza una ejecución. - Abre la última ejecución y espera hasta que la tarea
route_complaintmuestre el estado deferred. - En la pestaña Required Actions, selecciona Billing Issue y envía tu respuesta.
- Cambia a la vista Graph y mira el estado de cada tarea.
Después de seleccionar "Billing Issue", ¿qué ocurre con las tareas que no has seleccionado?
Este ejercicio forma parte del curso
Creación de canalizaciones de datos con Airflow
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio