show error when dag fails to parse 2

viaduct-ai · Jun 16, 2021 · 7455b93 · 7455b93
1 parent a9cdd89
commit 7455b93
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)