Retourner des données depuis une fonction TaskFlow
Votre équipe stocke la configuration du pipeline dans une tâche distincte pour pouvoir la réutiliser dans les étapes en aval. Centraliser la configuration de cette façon est courant en production : une tâche définit les paramètres, et toutes les autres lisent les mêmes valeurs au lieu de les coder en dur. La tâche get_config retourne déjà le dictionnaire de configuration, et run_pipeline est prêt à l'utiliser.
Cette activité fait partie du cours
Créer des pipelines de données avec Airflow
Exercice interactif pratique
Passez de la théorie à l’action grâce à l’un de nos exercices interactifs
Commencer l’exercice