From 7455b93b3fbba35fa2f481bfb0550b9f8e3e36fd Mon Sep 17 00:00:00 2001 From: looi Date: Wed, 16 Jun 2021 10:46:34 -0700 Subject: [PATCH] show error when dag fails to parse 2 --- dump_dags.py | 1 + 1 file changed, 1 insertion(+) diff --git a/dump_dags.py b/dump_dags.py index f344a39..553a301 100644 --- a/dump_dags.py +++ b/dump_dags.py @@ -6,6 +6,7 @@ def dump_dags(output_base_path): os.makedirs(output_base_path, exist_ok=True) bag = DagBag() + assert not dagbag.import_errors for dag_id in sorted(bag.dag_ids): dag = bag.get_dag(dag_id)