def run_all(self):
try:
self.api.connect()
except URLError as e:
self.application_logger.exception('Failed to connect to the server. Salt API URLError: %s',
e.args[0].strerror)
self.test_report_logger.debug(e)
exit(1)
# Run async tests
started_counter = 0
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
futures = []
for test in self.test_suite.test_cases_async:
self.application_logger.info('Start test ' + test.name)
futures.append(executor.submit(self._start_test_async, test))
for x in concurrent.futures.as_completed(futures):
if not x.result():
self.application_logger.error('Error starting async test')
executor.shutdown(wait=False)
exit(1)
started_counter += 1
self.application_logger.info('Started test %s of %s', started_counter,
len(self.test_suite.test_cases_async))
test_counter = 0
self.application_logger.info('----------------Started all tests-----------------')
for test in self.test_suite.test_cases_async:
self.application_logger.info('CollectResult of Test ' + test.name)
self._collect_result(test)
test_counter += 1
self.application_logger.info('Collected results from %s of %s tests', test_counter,
len(self.test_suite.test_cases_async))
self.application_logger.info('--------------Collected all results---------------')
# Run sync tests
for test in self.test_suite.test_cases_sync:
self.application_logger.info('Start Test ' + test.name)
self._start_test_sync(test)
self.application_logger.info('\n')
评论列表
文章目录