CommencerCommencez gratuitement

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>
Voir le cours

Exercice interactif pratique

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

Commencer l’exercice