diff --git a/airflow/providers/amazon/aws/operators/rds.py b/airflow/providers/amazon/aws/operators/rds.py index 2630098bc4650..c037251643094 100644 --- a/airflow/providers/amazon/aws/operators/rds.py +++ b/airflow/providers/amazon/aws/operators/rds.py @@ -62,8 +62,9 @@ def __init__( AirflowProviderDeprecationWarning, stacklevel=3, # 2 is in the operator's init, 3 is in the user code creating the operator ) - self.region_name = region_name - self.hook = RdsHook(aws_conn_id=aws_conn_id, region_name=region_name, **(hook_params or {})) + hook_params = hook_params or {} + self.region_name = region_name or hook_params.pop("region_name", None) + self.hook = RdsHook(aws_conn_id=aws_conn_id, region_name=self.region_name, **(hook_params)) super().__init__(*args, **kwargs) self._await_interval = 60 # seconds