Tests d'intégration avec dag.test()
Les tests d'intégrité valident le chargement et les tests unitaires valident la logique, mais aucun ne lance réellement le Dag. Les tests d'intégration avec dag.test() comblent cette lacune en exécutant toutes les tâches séquentiellement dans un seul processus. Un pipeline ETL nommé etl_output a été déployé ; il écrit ses résultats dans /tmp/etl_results.json.
Vous allez écrire un test d'intégration qui exécute l'ensemble du pipeline et vérifie sa sortie.
Cet exercice fait partie du cours
<cours>Créer des pipelines de données avec Airflow</cours>Exercice interactif pratique
Transformez la théorie en action avec l’un de nos exercices interactifs
Commencer l’exercice