refactor: pass CommitStats via extra kwarg

Author: larkee

google/cloud/spanner_v1/database.py

@@ -657,7 +657,10 @@ def __exit__(self, exc_type, exc_val, exc_tb):
                 self._batch.commit(return_commit_stats=self._database.log_commit_stats)
         finally:
             if self._database.log_commit_stats:
-                self._database.logger.info(self._batch.commit_stats)
+                self._database.logger.info(
+                    "CommitStats: {}".format(self._batch.commit_stats),
+                    extra={"commit_stats": self._batch.commit_stats},
+                )
             self._database._pool.put(self._session)
 
 

google/cloud/spanner_v1/session.py

@@ -358,7 +358,10 @@ def run_in_transaction(self, func, *args, **kw):
                 raise
             else:
                 if self._database.log_commit_stats:
-                    self._database.logger.info(txn.commit_stats)
+                    self._database.logger.info(
+                        "CommitStats: {}".format(txn.commit_stats),
+                        extra={"commit_stats": txn.commit_stats},
+                    )
                 return return_value
 
 

tests/unit/test_database.py

@@ -1374,7 +1374,9 @@ def test_context_mgr_w_commit_stats(self):
             request=request, metadata=[("google-cloud-resource-prefix", database.name)],
         )
 
-        database.logger.info.assert_called_once_with(commit_stats)
+        database.logger.info.assert_called_once_with(
+            "CommitStats: mutation_count: 4\n", extra={"commit_stats": commit_stats}
+        )
 
     def test_context_mgr_failure(self):
         from google.cloud.spanner_v1.batch import Batch

tests/unit/test_session.py

@@ -1378,7 +1378,9 @@ def unit_of_work(txn, *args, **kw):
         gax_api.commit.assert_called_once_with(
             request=request, metadata=[("google-cloud-resource-prefix", database.name)],
         )
-        database.logger.info.assert_called_once_with(commit_stats)
+        database.logger.info.assert_called_once_with(
+            "CommitStats: mutation_count: 4\n", extra={"commit_stats": commit_stats}
+        )
 
     def test_delay_helper_w_no_delay(self):
         from google.cloud.spanner_v1.session import _delay_until_retry