Merge pull request #255 from lzaoral/worker-do-not-accept-new-tasks-when-locked

worker: do not open additional tasks if the `TaskManager` is locked

Author: rohanpm

kobo/worker/taskmanager.py

@@ -313,6 +313,10 @@ def get_next_task(self):
 
         # process tasks that could be transitioned to the OPEN state
         for task_info in tasks_to_open:
+            # do not take additional tasks
+            if self.locked:
+                return
+
             self.take_task(task_info)
 
     def take_task(self, task_info):