From 954611d72da0808484aaa26ea22d16a718a15613 Mon Sep 17 00:00:00 2001 From: fritz-astronomer <80706212+fritz-astronomer@users.noreply.github.com> Date: Tue, 2 Jan 2024 16:50:19 -0500 Subject: [PATCH] Revert "Read DAGs from SerializedDagModel instead of DagBag" This reverts commit 89ec2ea7d073899a4442c67dbb3577fc006e4c9b. --- .../starship/services/local_airflow_client.py | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) diff --git a/astronomer_starship/starship/services/local_airflow_client.py b/astronomer_starship/starship/services/local_airflow_client.py index 65ec597..d6185b7 100644 --- 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