runner.py 文件源码

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')