From 3744d00c0d720384fe23f6bd2bbfcceacc4f95c5 Mon Sep 17 00:00:00 2001 From: Tuan Vu Minh Date: Fri, 4 Jul 2025 19:13:13 +0700 Subject: [PATCH] Add debug logging for endpoint_url in AWS Connection --- .../providers/amazon/aws/utils/connection_wrapper.py | 6 ++++++ 1 file changed, 6 insertions(+) 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