Tests: increased timeout in wait_for_record().
This commit is contained in:
@@ -377,7 +377,7 @@ Connection: close
|
||||
self.get(no_recv=True)
|
||||
|
||||
assert (
|
||||
self.wait_for_record(r'\(5\) Thread: 100') is not None
|
||||
self.wait_for_record(r'\(5\) Thread: 100', wait=50) is not None
|
||||
), 'last thread finished'
|
||||
|
||||
def test_asgi_application_threads(self):
|
||||
|
||||
@@ -569,7 +569,7 @@ last line: 987654321
|
||||
self.get(no_recv=True)
|
||||
|
||||
assert (
|
||||
self.wait_for_record(r'\(5\) Thread: 100') is not None
|
||||
self.wait_for_record(r'\(5\) Thread: 100', wait=50) is not None
|
||||
), 'last thread finished'
|
||||
|
||||
def test_python_application_iter_exception(self):
|
||||
|
||||
@@ -19,8 +19,8 @@ class TestApplicationProto(TestControl):
|
||||
with open(option.temp_dir + '/' + name, 'r', errors='ignore') as f:
|
||||
return re.search(pattern, f.read())
|
||||
|
||||
def wait_for_record(self, pattern, name='unit.log'):
|
||||
for i in range(50):
|
||||
def wait_for_record(self, pattern, name='unit.log', wait=150):
|
||||
for i in range(wait):
|
||||
found = self.search_in_log(pattern, name)
|
||||
|
||||
if found is not None:
|
||||
|
||||
Reference in New Issue
Block a user