From 5e4a04c4f0016d9d8ac2c35f0b1c47ba38f7410f Mon Sep 17 00:00:00 2001 From: Alex Beach Date: Wed, 27 Jun 2018 11:55:43 -0400 Subject: [PATCH] revert return --- henson_sqs/__init__.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/henson_sqs/__init__.py b/henson_sqs/__init__.py index 5c9145e..bf1714b 100644 --- a/henson_sqs/__init__.py +++ b/henson_sqs/__init__.py @@ -80,7 +80,7 @@ def _begin_consuming(self): maxsize=self.app.settings['SQS_PREFETCH_LIMIT'], loop=loop, ) - return loop.create_task(self._consume()) + loop.create_task(self._consume()) @asyncio.coroutine def _consume(self):