DAG tests

DAG tests check that an Airflow pipeline is correct before deployment: loading without import errors, no cycles, presence of the expected tasks and dependencies, and the logic of the transformation functions. A classic test loads the DagBag and checks that it contains no errors.

Example

dag_bag = DagBag(include_examples=False)
assert not dag_bag.import_errors

Related concepts

The whole glossary