Add missing await

neo4j · Jan 19, 2022 · 423e1e5 · 423e1e5
1 parent f2def4b
commit 423e1e5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/neo4j/_async/work/session.py b/neo4j/_async/work/session.py
@@ -295,7 +295,7 @@ async def begin_transaction(self, metadata=None, timeout=None):
         # TODO: Implement TransactionConfig consumption
 
         if self._auto_result:
-            self._auto_result.consume()
+            await self._auto_result.consume()
 
         if self._transaction:
             raise TransactionError("Explicit transaction already open")