This folder contains DAGs for Airflow unit testing. These files contain defects that prevent the default Python interpreter from loading this file.
To access a DAG in this folder, use the following code inside a unit test.
TEST_DAG_FOLDER = os.path.join(os.path.dirname(os.path.realpath(__file__)), "dags_corrupted") dagbag = DagBag(dag_folder=TEST_DAG_FOLDER) dag = dagbag.get_dag(dag_id)