diff --git a/airflow-core/src/airflow/models/dag.py b/airflow-core/src/airflow/models/dag.py index 57c1050e3ce94..77f96d590cc5e 100644 --- a/airflow-core/src/airflow/models/dag.py +++ b/airflow-core/src/airflow/models/dag.py @@ -1794,7 +1794,7 @@ def create_tasks(task): if isinstance(task, TaskGroup): return task_group_map[task.group_id] - new_task = copy.deepcopy(task) + new_task = copy.copy(task) # Only overwrite the specific attributes we want to change new_task.task_id = task.task_id