This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 7a834d6e866 Fix task SDK connection error handling to match
airflow-core behavior (#56650)
7a834d6e866 is described below
commit 7a834d6e86666e8f9b0ec53b1bc2c1236770d663
Author: Amogh Desai <[email protected]>
AuthorDate: Wed Oct 15 15:11:50 2025 +0530
Fix task SDK connection error handling to match airflow-core behavior
(#56650)
---
task-sdk/src/airflow/sdk/execution_time/context.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/execution_time/context.py
b/task-sdk/src/airflow/sdk/execution_time/context.py
index ae916aefea0..58bd2521b02 100644
--- a/task-sdk/src/airflow/sdk/execution_time/context.py
+++ b/task-sdk/src/airflow/sdk/execution_time/context.py
@@ -160,7 +160,7 @@ def _get_connection(conn_id: str) -> Connection:
_mask_connection_secrets(conn)
return conn
except Exception:
- log.exception(
+ log.debug(
"Unable to retrieve connection from secrets backend (%s). "
"Checking subsequent secrets backend.",
type(secrets_backend).__name__,
@@ -206,7 +206,7 @@ async def _async_get_connection(conn_id: str) -> Connection:
return conn
except Exception:
# If one backend fails, try the next one
- log.exception(
+ log.debug(
"Unable to retrieve connection from secrets backend (%s). "
"Checking subsequent secrets backend.",
type(secrets_backend).__name__,
