Définir l’ordre des tâches
Maintenant que vous avez vu la syntaxe de décalage de bits, il est temps de définir l’ordre d’exécution des tâches. Vous disposez de trois tâches déjà définies : cleanup, consolidate et push_data.
Les décorateurs dag et task de airflow.sdk sont déjà importés.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Configurez la tâche
cleanuppour qu’elle s’exécute en premier, avant la tâcheconsolidate, en utilisant la syntaxe de décalage de bits. - Configurez
consolidatepour qu’elle s’exécute ensuite et la tâchepush_datapour qu’elle s’exécute en dernier.
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()