Alway start workers for slow tasks
This commit is contained in:
parent
604792a4dd
commit
53afd97346
1 changed files with 1 additions and 1 deletions
|
@ -99,7 +99,7 @@ class WorkerManager(object):
|
||||||
if task["peers"]: # Release the peer lock
|
if task["peers"]: # Release the peer lock
|
||||||
self.log.debug("Task peer lock release: %s" % task["inner_path"])
|
self.log.debug("Task peer lock release: %s" % task["inner_path"])
|
||||||
task["peers"] = []
|
task["peers"] = []
|
||||||
self.startWorkers()
|
self.startWorkers()
|
||||||
|
|
||||||
if len(self.tasks) > len(self.workers) * 2 and len(self.workers) < self.getMaxWorkers():
|
if len(self.tasks) > len(self.workers) * 2 and len(self.workers) < self.getMaxWorkers():
|
||||||
self.startWorkers()
|
self.startWorkers()
|
||||||
|
|
Loading…
Reference in a new issue