Les tests de DAG vérifient qu'un pipeline Airflow est correct avant déploiement : chargement sans erreur d'import, absence de cycle, présence des tâches et dépendances attendues, et logique des fonctions de transformation. Un test classique charge le DagBag et contrôle qu'il ne contient aucune erreur.
Exemple
dag_bag = DagBag(include_examples=False)
assert not dag_bag.import_errors