Définir l’ordre d’exécution du pipeline
Après avoir créé votre DAG, il est temps de définir l’ordre d’exécution des tâches du DAG.
Dans l’exercice précédent, vous avez configuré la première tâche pour vérifier l’API. Toutes les autres tâches du pipeline sont déjà prêtes pour vous.
Vous devez suivre l’ordre des tâches indiqué dans le schéma ci-dessous.
Cet exercice fait partie du cours
<cours>Concevoir des pipelines de prévision pour la production</cours>Instructions de l’exercice
- Définissez les tâches du pipeline de vérification de l’API et de contrôle du statut.
- Définissez les tâches du pipeline de validation des données.
- Définissez les tâches du pipeline de prévision.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# Set the API check pipeline tasks
____ >> ____ >> [data_refresh, no_updates]
data_refresh >> [data_validation, data_failure]
# Set the data validation pipeline tasks
data_validation >> check_validation >> [____, ____]
# Set the forecast pipeline tasks
data_valid >> ____ >> ____
print(f"DAG '{dag.dag_id}' ready with {len(dag.tasks)} tasks")