Revert "Read DAGs from SerializedDagModel instead of DagBag"

This reverts commit 89ec2ea.
astronomer · Jan 2, 2024 · 954611d · 954611d
1 parent 5fddd5f
commit 954611d
Showing 1 changed file with 1 addition and 12 deletions.
diff --git a/astronomer_starship/starship/services/local_airflow_client.py b/astronomer_starship/starship/services/local_airflow_client.py
@@ -47,18 +47,7 @@ def get_variable(variable: str):
 
 @ttl_cache(ttl=60)
 def get_dags():
-    dags = {}
-    try:
-        dags = DagBag(read_dags_from_db=True).dags
-    except Exception as e:
-        logging.exception(e)
-        print(e)
-    if not len(dags):
-        try:
-            dags = DagBag().dags
-        except Exception as e:
-            logging.exception(e)
-            print(e)
+    dags = DagBag().dags
     return dags