This is an automated email from the ASF dual-hosted git repository.
potiuk 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 e0a4197 Improve postgres provider logging (#17214)
e0a4197 is described below
commit e0a41971a1c57221a5e03c70fc670a4c09f19d8a
Author: Mayank Sardana <[email protected]>
AuthorDate: Tue Jul 27 03:50:40 2021 -0400
Improve postgres provider logging (#17214)
* Remove duplicated logging of sql
* Add logging for copy expert sql
---
airflow/providers/postgres/hooks/postgres.py | 1 +
airflow/providers/postgres/operators/postgres.py | 1 -
2 files changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/postgres/hooks/postgres.py
b/airflow/providers/postgres/hooks/postgres.py
index 35ed59f..4e54cf9 100644
--- a/airflow/providers/postgres/hooks/postgres.py
+++ b/airflow/providers/postgres/hooks/postgres.py
@@ -125,6 +125,7 @@ class PostgresHook(DbApiHook):
So if users want to be aware when the input file does not exist,
they have to check its existence by themselves.
"""
+ self.log.info("Running copy expert: %s, filename: %s", sql, filename)
if not os.path.isfile(filename):
with open(filename, 'w'):
pass
diff --git a/airflow/providers/postgres/operators/postgres.py
b/airflow/providers/postgres/operators/postgres.py
index b28cd48..e4ef23f 100644
--- a/airflow/providers/postgres/operators/postgres.py
+++ b/airflow/providers/postgres/operators/postgres.py
@@ -65,7 +65,6 @@ class PostgresOperator(BaseOperator):
self.hook = None
def execute(self, context):
- self.log.info('Executing: %s', self.sql)
self.hook = PostgresHook(postgres_conn_id=self.postgres_conn_id,
schema=self.database)
self.hook.run(self.sql, self.autocommit, parameters=self.parameters)
for output in self.hook.conn.notices:
