[airflow] branch main updated: DbApiHook consistent insert_rows logging (#26758)

[po...@apache.org]

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 76014609c0 DbApiHook consistent insert_rows logging (#26758)
76014609c0 is described below

commit 76014609c07bfa307ef7598794d1c0404c5279bd
Author: Pavel T <pa...@gmail.com>
AuthorDate: Sun Oct 9 23:46:51 2022 -0400

    DbApiHook consistent insert_rows logging (#26758)
---
 airflow/providers/common/sql/hooks/sql.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/common/sql/hooks/sql.py b/airflow/providers/common/sql/hooks/sql.py
index 6fbf7027f2..e87f7071fa 100644
--- a/airflow/providers/common/sql/hooks/sql.py
+++ b/airflow/providers/common/sql/hooks/sql.py
@@ -414,7 +414,7 @@ class DbApiHook(BaseForDbApiHook):
                         self.log.info("Loaded %s rows into %s so far", i, table)
 
             conn.commit()
-        self.log.info("Done loading. Loaded a total of %s rows", i)
+        self.log.info("Done loading. Loaded a total of %s rows into %s", i, table)
 
     @staticmethod
     def _serialize_cell(cell, conn=None):