Convertir un Dag classique en TaskFlow
Votre équipe a décidé d'adopter l'API TaskFlow pour tous les nouveaux pipelines. Votre manager vous demande de réécrire un pipeline ETL existant qui utilisait PythonOperator avec un chaînage manuel via >>.
La version classique d'origine est disponible comme référence dans dags/classic_etl.py. Un squelette en TaskFlow est prêt pour que vous le complétiez.
Cet exercice fait partie du cours
<cours>Créer des pipelines de données avec Airflow</cours>Exercice interactif pratique
Transformez la théorie en action avec l’un de nos exercices interactifs
Commencer l’exercice