From 35270dd970de01fd164a9a724e46f5b7bb8196cb Mon Sep 17 00:00:00 2001 From: Michael Montgomery Date: Sat, 1 Apr 2017 11:23:38 -0500 Subject: [PATCH] Fixing sqs drain_events issues (#698) --- kombu/transport/SQS.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index 1e8ef6db..a0fb6e8d 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -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: