Updated queue.Full logger.error to logger.warning and added bare except for subprocess.check_output function call for windows
This commit is contained in:
parent
0d6992dc8a
commit
e8b80f6117
|
@ -69,7 +69,7 @@ class FakeAddressGenerator(StoppableThread):
|
||||||
try:
|
try:
|
||||||
queues.addressGeneratorQueue.put(("stopThread", "data"))
|
queues.addressGeneratorQueue.put(("stopThread", "data"))
|
||||||
except queue.Full:
|
except queue.Full:
|
||||||
self.logger.error('addressGeneratorQueue is Full')
|
self.logger.warning('addressGeneratorQueue is Full')
|
||||||
super(FakeAddressGenerator, self).stopThread()
|
super(FakeAddressGenerator, self).stopThread()
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
|
|
|
@ -149,6 +149,8 @@ class TestProcessProto(unittest.TestCase):
|
||||||
]).split()
|
]).split()
|
||||||
except subprocess.CalledProcessError:
|
except subprocess.CalledProcessError:
|
||||||
thread_names = []
|
thread_names = []
|
||||||
|
except: # noqa:E722
|
||||||
|
thread_names = []
|
||||||
|
|
||||||
running_threads = len(thread_names)
|
running_threads = len(thread_names)
|
||||||
if 0 < running_threads < 30: # adequacy check
|
if 0 < running_threads < 30: # adequacy check
|
||||||
|
|
Reference in New Issue
Block a user