CommencezCommencez gratuitement

Convertir un Dag classique en TaskFlow

Votre équipe a décidé d'adopter l'API TaskFlow pour tous les nouveaux pipelines. Votre gestionnaire vous demande de réécrire un pipeline ETL existant qui utilisait PythonOperator avec un chaînage manuel >>.

La version classique originale est disponible comme référence dans dags/classic_etl.py. Une version amorcée avec TaskFlow est prête pour que vous la complétiez.

Cette activité fait partie du cours

Créer des pipelines de données avec Airflow

Voir le cours

Exercice interactif pratique

Passez de la théorie à l’action grâce à l’un de nos exercices interactifs

Commencer l’exercice