From 5de6e261815afd38664858dcf2ad037de38431d2 Mon Sep 17 00:00:00 2001 From: syahril Date: Wed, 21 Oct 2026 15:14:21 +0700 Subject: [PATCH] fix(dag_factory): safely clean task_group child on fallback --- dags/dag_factory.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/dags/dag_factory.py b/dags/dag_factory.py index 7991feb..03ae9e7 100644 --- a/dags/dag_factory.py +++ b/dags/dag_factory.py @@ -556,6 +556,8 @@ def build_dag_from_yaml(config_file: str) -> DAG: ) except Exception as e: print(f"[COSMOS_FALLBACK] Error creating DbtTaskGroup for {t_id}: {e}") + if hasattr(dag, 'task_group') and t_id in dag.task_group.children: + del dag.task_group.children[t_id] task_obj = DbtTrinoIcebergOperator( task_id=t_id, select_models=select_m,