Merge pull request #28 from iheartradio/revert-bug-fix

revert return
iheartradio · Jun 27, 2018 · a4038a2 · a4038a2
2 parents 0189b0e + 5e4a04c
commit a4038a2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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):