queue block is true by default.

2026-09-25 16:18:12 +08:00 · 2015-07-24 10:52:30 +02:00
parent d31e9e2b97
commit cf325f8199
1 changed files with 1 additions and 1 deletions
@@ -314,7 +314,7 @@ def pusher(task_queue, event, list_key=Conf.Q_LIST, r=redis_client):
            sleep(10)
            break
        if task:
-            task_queue.put(task[1], block=True)
+            task_queue.put(task[1])
            logger.debug(_('queueing from {}').format(list_key))
        if event.is_set():
            break