Rev2002, Fix exception on startworkers
This commit is contained in:
parent
7705cb1158
commit
f55c2659cd
2 changed files with 2 additions and 2 deletions
|
@ -10,7 +10,7 @@ class Config(object):
|
||||||
|
|
||||||
def __init__(self, argv):
|
def __init__(self, argv):
|
||||||
self.version = "0.5.3"
|
self.version = "0.5.3"
|
||||||
self.rev = 1999
|
self.rev = 2002
|
||||||
self.argv = argv
|
self.argv = argv
|
||||||
self.action = None
|
self.action = None
|
||||||
self.config_file = "zeronet.conf"
|
self.config_file = "zeronet.conf"
|
||||||
|
|
|
@ -88,7 +88,7 @@ class WorkerManager(object):
|
||||||
self.startFindOptional(find_more=True)
|
self.startFindOptional(find_more=True)
|
||||||
elif task["peers"]:
|
elif task["peers"]:
|
||||||
if not self.workers:
|
if not self.workers:
|
||||||
self.startWorkers(peer for peer in task["peers"] if peer not in task["failed"])
|
self.startWorkers([peer for peer in task["peers"] if peer not in task["failed"]])
|
||||||
else:
|
else:
|
||||||
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"])
|
||||||
|
|
Loading…
Reference in a new issue