CommencerCommencez gratuitement

Renvoyer des données depuis une fonction TaskFlow

Votre équipe stocke la configuration du pipeline dans une tâche séparée afin qu'elle puisse être réutilisée dans les étapes en aval. Centraliser la configuration de cette manière 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 renvoie déjà le dictionnaire de configuration, et run_pipeline est prête à l'utiliser.

Cet exercice fait partie du cours

<cours>Créer des pipelines de données avec Airflow</cours>
Voir le cours

Exercice interactif pratique

Transformez la théorie en action avec l’un de nos exercices interactifs

Commencer l’exercice