EdwardRadical

Same core issue as https://github.com/apache/airflow/issues/23621. >This logic already exists; a @task-decorated task calls get_unique_task_id, which calls task_group.child_id. The root cause will be deeper than this. As far as I can...

No, @uranusjr, there is more to it. This is the complete snippet: ``` task_group = task_group or TaskGroupContext.get_current_task_group(dag) tg_task_id = task_group.child_id(task_id) if task_group else task_id if tg_task_id not in dag.task_ids:...