Skip to content
Snippets Groups Projects
Commit ffa876a6 authored by Christos Stavrakakis's avatar Christos Stavrakakis
Browse files

common: Fix type error issue

Fix TypError issue cause by an unknown 'timeout' argument to
'get_confirms' call.
parent f7ed7fa7
No related branches found
No related tags found
No related merge requests found
...@@ -414,7 +414,7 @@ class AMQPPukaClient(object): ...@@ -414,7 +414,7 @@ class AMQPPukaClient(object):
# Try to get confirmations # Try to get confirmations
if self.confirms and self.unacked: if self.confirms and self.unacked:
self.log.debug("Getting pending publisher confirmations..") self.log.debug("Getting pending publisher confirmations..")
self.get_confirms(timeout=timeout) self.get_confirms()
# And close the connection # And close the connection
close_promise = self.client.close() close_promise = self.client.close()
self.log.debug("Waiting for connection to close..") self.log.debug("Waiting for connection to close..")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment