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 ffe4fcfb96d Log SQL query on its own line in BigQueryInsertJobOperator
(#69386)
ffe4fcfb96d is described below
commit ffe4fcfb96d3ac3cb7ee5eadb7919800b5c4e3bb
Author: Morgan <[email protected]>
AuthorDate: Mon Jul 6 08:56:50 2026 -0300
Log SQL query on its own line in BigQueryInsertJobOperator (#69386)
Co-authored-by: Lucho Formisano
<[email protected]>
---
.../google/src/airflow/providers/google/cloud/operators/bigquery.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git
a/providers/google/src/airflow/providers/google/cloud/operators/bigquery.py
b/providers/google/src/airflow/providers/google/cloud/operators/bigquery.py
index d182ef4b6c6..06b9e905555 100644
--- a/providers/google/src/airflow/providers/google/cloud/operators/bigquery.py
+++ b/providers/google/src/airflow/providers/google/cloud/operators/bigquery.py
@@ -2474,7 +2474,9 @@ class BigQueryInsertJobOperator(GoogleCloudBaseOperator,
_BigQueryInsertJobOpera
)
try:
- self.log.info("Executing: %s'", self.configuration)
+ self.log.info("Executing: %s", self.configuration)
+ if self.sql:
+ self.log.info("SQL query:\n%s", self.sql)
# Create a job
if self.job_id is None:
raise ValueError("job_id cannot be None")
