This is an automated email from the ASF dual-hosted git repository.
shahar1 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 0d209e60b0c Log check_query_output response via format string in
Snowflake SQL API hook (#67848)
0d209e60b0c is described below
commit 0d209e60b0c768a29cb2607439c003577f1e8899
Author: michaelneely <[email protected]>
AuthorDate: Fri Jul 24 16:57:17 2026 +0100
Log check_query_output response via format string in Snowflake SQL API hook
(#67848)
---
.../src/airflow/providers/snowflake/hooks/snowflake_sql_api.py | 2 +-
.../snowflake/tests/unit/snowflake/hooks/test_snowflake_sql_api.py | 4 +++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git
a/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake_sql_api.py
b/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake_sql_api.py
index e61783f6ed7..52d26513d28 100644
---
a/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake_sql_api.py
+++
b/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake_sql_api.py
@@ -324,7 +324,7 @@ class SnowflakeSqlApiHook(SnowflakeHook):
_, response_json = self._make_api_call_with_retries(
method="GET", url=url, headers=header, params=params
)
- self.log.info(response_json)
+ self.log.info("Snowflake SQL API result for query %s: %s",
query_id, response_json)
def _process_response(self, status_code, resp):
self.log.info("Snowflake SQL GET statements status API response: %s",
resp)
diff --git
a/providers/snowflake/tests/unit/snowflake/hooks/test_snowflake_sql_api.py
b/providers/snowflake/tests/unit/snowflake/hooks/test_snowflake_sql_api.py
index 0ce7a0bf88d..a7f808c390d 100644
--- a/providers/snowflake/tests/unit/snowflake/hooks/test_snowflake_sql_api.py
+++ b/providers/snowflake/tests/unit/snowflake/hooks/test_snowflake_sql_api.py
@@ -472,7 +472,9 @@ class TestSnowflakeSqlApiHook:
hook = SnowflakeSqlApiHook("mock_conn_id")
with mock.patch.object(hook.log, "info") as mock_log_info:
hook.check_query_output(query_ids)
- mock_log_info.assert_called_with(GET_RESPONSE)
+ mock_log_info.assert_called_with(
+ "Snowflake SQL API result for query %s: %s", query_ids[-1],
GET_RESPONSE
+ )
@pytest.mark.parametrize("query_ids", [["uuid", "uuid1"]])
@mock.patch(f"{HOOK_PATH}.get_request_url_header_params")
