diff --git a/providers/amazon/src/airflow/providers/amazon/aws/utils/connection_wrapper.py b/providers/amazon/src/airflow/providers/amazon/aws/utils/connection_wrapper.py index 4d10856490ff6..bcbf3d3857c8a 100644 --- a/providers/amazon/src/airflow/providers/amazon/aws/utils/connection_wrapper.py +++ b/providers/amazon/src/airflow/providers/amazon/aws/utils/connection_wrapper.py @@ -248,6 +248,12 @@ def __post_init__(self, conn: Connection | AwsConnectionWrapper | _ConnectionMet config_kwargs["signature_version"] = UNSIGNED self.botocore_config = Config(**config_kwargs) + if "endpoint_url" not in extra: + self.log.debug( + "Missing endpoint_url in extra config of AWS Connection with id %s. Using default AWS service endpoint", + conn.conn_id, + ) + self.endpoint_url = extra.get("endpoint_url") # Retrieve Assume Role Configuration