From e85efe2c64e681ad0cf17fcdfa5aa6fd0177cc8e Mon Sep 17 00:00:00 2001 From: shortcutme Date: Tue, 3 Oct 2017 15:52:04 +0200 Subject: [PATCH] Restart find optional files algorithm if new task started since running the function --- src/Worker/WorkerManager.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/Worker/WorkerManager.py b/src/Worker/WorkerManager.py index e97037e6..2af1b511 100644 --- a/src/Worker/WorkerManager.py +++ b/src/Worker/WorkerManager.py @@ -356,6 +356,10 @@ class WorkerManager(object): if len(found) < len(optional_hash_ids): self.log.debug("No findhash result for optional files: %s" % (optional_hash_ids - set(found))) + if time_tasks != self.time_task_added: # New task added since start + self.log.debug("New task since start, restarting...") + gevent.spawn_later(0.1, self.startFindOptional) + # Stop all worker def stopWorkers(self): for worker in self.workers.values():