diff --git a/src/Worker/WorkerManager.py b/src/Worker/WorkerManager.py index 2b8ba664..bd45a12b 100644 --- a/src/Worker/WorkerManager.py +++ b/src/Worker/WorkerManager.py @@ -59,6 +59,7 @@ class WorkerManager(object): worker.skip() else: self.failTask(task) + elif time.time() >= task["time_added"] + 60 and not self.workers: # No workers left self.log.debug("Timeout, Cleanup task: %s" % task) # Remove task @@ -420,7 +421,6 @@ class WorkerManager(object): self.log.debug("Starting new workers... (tasks: %s)" % len(self.tasks)) self.startWorkers() - # Tasks sorted by this def getPriorityBoost(self, inner_path): if inner_path == "content.json": @@ -518,7 +518,7 @@ class WorkerManager(object): def checkComplete(self): time.sleep(0.1) if not self.tasks: - self.log.debug("Check compelte: No tasks") + self.log.debug("Check complete: No tasks") self.onComplete() def onComplete(self):