Logging

Author: technige

neo4j/__init__.py

@@ -71,6 +71,7 @@
 
 from collections import deque, namedtuple
 from functools import reduce
+from logging import getLogger
 from operator import xor as xor_operator
 from random import random
 from time import sleep
@@ -95,6 +96,9 @@
 STATEMENT_TYPE_SCHEMA_WRITE = "s"
 
 
+log = getLogger("neo4j")
+
+
 # TODO: remove in 2.0
 _warned_about_transaction_bookmarks = False
 
@@ -690,7 +694,10 @@ def _run_transaction(self, access_mode, unit_of_work, *args, **kwargs):
             t1 = perf_counter()
             if t1 - t0 > self._max_retry_time:
                 break
-            sleep(next(retry_delay))
+            delay = next(retry_delay)
+            log.warning("Transaction failed and will be retried in {}s "
+                        "({})".format(delay, "; ".join(errors[-1].args)))
+            sleep(delay)
         if errors:
             raise errors[-1]
         else:

requirements.txt

@@ -1,2 +1,2 @@
-neobolt<2,>=1.7.6
+neobolt<2,>=1.7.7
 neotime<2,>=1.7.1

setup.py

@@ -30,7 +30,7 @@
 from neo4j.meta import package, version
 
 install_requires = [
-    "neobolt<2,>=1.7.6",
+    "neobolt<2,>=1.7.7",
     "neotime<2,>=1.7.1",
 ]
 classifiers = [