This is an automated email from the ASF dual-hosted git repository.
uranusjr 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 254a4efc6bf fix: logs SQL before execution in `ExasolHook` (#48688)
254a4efc6bf is described below
commit 254a4efc6bf60f1eba2670c5fd9bce4ec0079585
Author: Guan Ming(Wesley) Chiu <[email protected]>
AuthorDate: Thu Apr 3 16:15:22 2025 +0800
fix: logs SQL before execution in `ExasolHook` (#48688)
---
providers/exasol/src/airflow/providers/exasol/hooks/exasol.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/providers/exasol/src/airflow/providers/exasol/hooks/exasol.py
b/providers/exasol/src/airflow/providers/exasol/hooks/exasol.py
index 69c51ab4c8e..27bab93afbb 100644
--- a/providers/exasol/src/airflow/providers/exasol/hooks/exasol.py
+++ b/providers/exasol/src/airflow/providers/exasol/hooks/exasol.py
@@ -234,8 +234,8 @@ class ExasolHook(DbApiHook):
self.set_autocommit(conn, autocommit)
results = []
for sql_statement in sql_list:
+ self.log.info("Running statement: %s, parameters: %s",
sql_statement, parameters)
with closing(conn.execute(sql_statement, parameters)) as
exa_statement:
- self.log.info("Running statement: %s, parameters: %s",
sql_statement, parameters)
if handler is not None:
result = self._make_common_data_structure( # type:
ignore[attr-defined]
handler(exa_statement)
