This is an automated email from the ASF dual-hosted git repository.
eladkal 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 f56bcf73999 enhance: logs SQL before execution in `snowflake` and
`databricks_sql` (#48942)
f56bcf73999 is described below
commit f56bcf73999a1a1138b3e76cd9244187d4e0e852
Author: Guan Ming(Wesley) Chiu <[email protected]>
AuthorDate: Tue Apr 22 13:27:47 2025 +0800
enhance: logs SQL before execution in `snowflake` and `databricks_sql`
(#48942)
---
.../databricks/src/airflow/providers/databricks/hooks/databricks_sql.py | 1 +
providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake.py | 1 +
2 files changed, 2 insertions(+)
diff --git
a/providers/databricks/src/airflow/providers/databricks/hooks/databricks_sql.py
b/providers/databricks/src/airflow/providers/databricks/hooks/databricks_sql.py
index 80714c8e4a3..ea8b722928f 100644
---
a/providers/databricks/src/airflow/providers/databricks/hooks/databricks_sql.py
+++
b/providers/databricks/src/airflow/providers/databricks/hooks/databricks_sql.py
@@ -243,6 +243,7 @@ class DatabricksSqlHook(BaseDatabricksHook, DbApiHook):
conn = None
results = []
for sql_statement in sql_list:
+ self.log.info("Running statement: %s, parameters: %s",
sql_statement, parameters)
# when using AAD tokens, it could expire if previous query run
longer than token lifetime
conn = self.get_conn()
with closing(conn.cursor()) as cur:
diff --git
a/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake.py
b/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake.py
index 97966382501..eb77129b65d 100644
--- a/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake.py
+++ b/providers/snowflake/src/airflow/providers/snowflake/hooks/snowflake.py
@@ -502,6 +502,7 @@ class SnowflakeHook(DbApiHook):
with self._get_cursor(conn, return_dictionaries) as cur:
results = []
for sql_statement in sql_list:
+ self.log.info("Running statement: %s, parameters: %s",
sql_statement, parameters)
self._run_command(cur, sql_statement, parameters) # type:
ignore[attr-defined]
if handler is not None:
