Définir l'ordre des tâches
Maintenant que vous avez vu la syntaxe bitshift, il est temps de définir l'ordre d'exécution des tâches. Vous avez 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.
Cette activité fait partie du cours
Introduction à Apache Airflow en Python
Instructions de l’exercice
- Configurez la tâche
cleanuppour qu'elle s'exécute d'abord avant la tâcheconsolidate, en utilisant la syntaxe bitshift. - Configurez
consolidatepour s'exécuter ensuite et la tâchepush_datapour s'exécuter en dernier.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
@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()