Merge pull request #9 from chnpmy/master

fix: check pending tasks correctly, fix #8
cr0hn · Dec 27, 2017 · 1a3ca48 · 1a3ca48
2 parents 53214a6 + a808557
commit 1a3ca48
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/aiotasks/tasks/redis.py b/aiotasks/tasks/redis.py
@@ -135,7 +135,7 @@ def __init__(self,
 
     async def has_pending_tasks(self):
         return bool(self.task_running_tasks) \
-               or not bool(await self._redis_poller.llen(self.task_list_name))
+               or bool(await self._redis_poller.llen(self.task_list_name))
 
     def stop_delayers(self):
         self._redis_consumer.close()