oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix typo

Browse source
This commit is contained in:
shortcutme 2018-03-18 21:27:26 +01:00
parent ccdfe77356
commit e96435378a
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/Worker/WorkerManager.py
View file

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