SubprocessorBase fix

This commit is contained in:
iperov 2018-12-25 19:48:34 +04:00
parent e4010d3eba
commit 6f99f14a6d

View file

@ -94,7 +94,7 @@ class SubprocessorBase(object):
cq = multiprocessing.Queue()
client_dict.update ( {'print_lock' : self.print_lock} )
try:
p = multiprocessing.Process(target=self.subprocess, args=(sq,cq,client_dict))
p.daemon = True
p.start()
@ -106,6 +106,11 @@ class SubprocessorBase(object):
'name': name,
'host_dict' : host_dict
} )
except:
print ("Unable to start subprocess %s" % (name))
if len(self.processes) == 0:
raise Exception ("Unable to start Subprocessor '%s' " % (self.name))
while True:
for p in self.processes[:]: