Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixing sqs drain_events issues (#698)

This commit is contained in:
Michael Montgomery 2017-04-01 11:23:38 -05:00 committed by Asif Saifuddin Auvi
parent 3bc3b3d3b6
commit 35270dd970
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kombu/transport/SQS.py
View File

@ -132,7 +132,7 @@ class Channel(virtual.Channel):
self._noack_queues.discard(queue)
return super(Channel, self).basic_cancel(consumer_tag)
def drain_events(self, timeout=None):
def drain_events(self, timeout=None, **kwargs):
"""Return a single payload message from one of our queues.
Raises: