Skip to content

Commit bfbada3

Browse files
committed
Moved ack_failure call
1 parent 9fdaaac commit bfbada3

File tree

2 files changed

+1
-1
lines changed

2 files changed

+1
-1
lines changed

neo4j/v1/bolt.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -350,7 +350,6 @@ def fetch(self):
350350
elif signature == FAILURE:
351351
response = self.responses.popleft()
352352
response.complete = True
353-
self.acknowledge_failure()
354353
response.on_failure(*fields)
355354
else:
356355
raise ProtocolError("Unexpected response message with signature %02X" % signature)

neo4j/v1/session.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -230,6 +230,7 @@ def on_footer(metadata):
230230

231231
def on_failure(metadata):
232232
# Called on execution failure.
233+
self.connection.acknowledge_failure()
233234
self._consumed = True
234235
raise CypherError(metadata)
235236

0 commit comments

Comments
 (0)