Convertir un Dag clásico a TaskFlow
Tu equipo ha decidido adoptar la API de TaskFlow para todos los nuevos pipelines. Tu responsable te pide que reescribas un pipeline ETL existente que usaba PythonOperator con el encadenado manual >>.
La versión clásica original está disponible como referencia en dags/classic_etl.py. Tienes una versión con andamiaje de TaskFlow lista para que la completes.
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