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)