Use exiting recursive dict merge helper

airflow/providers/amazon/aws/executors/ecs/ecs_executor.py

@@ -41,11 +41,11 @@
     EcsExecutorException,
     EcsQueuedTask,
     EcsTaskCollection,
-    _deep_update,
 )
 from airflow.providers.amazon.aws.executors.utils.exponential_backoff_retry import exponential_backoff_retry
 from airflow.providers.amazon.aws.hooks.ecs import EcsHook
 from airflow.utils import timezone
+from airflow.utils.helpers import merge_dicts
 from airflow.utils.state import State
 
 if TYPE_CHECKING:
@@ -408,7 +408,7 @@ def _run_task_kwargs(
         One last chance to modify Boto3's "run_task" kwarg params before it gets passed into the Boto3 client.
         """
         run_task_kwargs = deepcopy(self.run_task_kwargs)
-        run_task_kwargs = _deep_update(run_task_kwargs, exec_config)
+        run_task_kwargs = merge_dicts(run_task_kwargs, exec_config)
         container_override = self.get_container(run_task_kwargs["overrides"]["containerOverrides"])
         container_override["command"] = cmd
 

airflow/providers/amazon/aws/executors/ecs/utils.py

@@ -264,16 +264,3 @@ def camelize_dict_keys(nested_dict) -> dict:
         else:
             result[new_key] = nested_dict[key]
     return result
-
-
-def _deep_update(dest_dict: dict, source_dict: dict) -> dict:
-    """Deep updates dest_dict with the values from source_dict."""
-    for key, value in source_dict.items():
-        if key in dest_dict and isinstance(dest_dict[key], dict) and isinstance(value, dict):
-            # Recursively update nested dictionaries
-            _deep_update(dest_dict[key], value)
-        else:
-            # Update or add key-value pairs
-            dest_dict[key] = value
-
-    return dest_dict