diff --git a/airflow-core/src/airflow/models/dag.py b/airflow-core/src/airflow/models/dag.py index 84055c6082639..5cc4e07495738 100644 --- a/airflow-core/src/airflow/models/dag.py +++ b/airflow-core/src/airflow/models/dag.py @@ -1808,7 +1808,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