diff options
Diffstat (limited to 'functest_kubernetes')
-rw-r--r-- | functest_kubernetes/k8stest.py | 19 | ||||
-rw-r--r-- | functest_kubernetes/test_k8stest.py | 5 |
2 files changed, 16 insertions, 8 deletions
diff --git a/functest_kubernetes/k8stest.py b/functest_kubernetes/k8stest.py index 2977bb81..95ebc321 100644 --- a/functest_kubernetes/k8stest.py +++ b/functest_kubernetes/k8stest.py @@ -47,21 +47,28 @@ class K8sTesting(testcase.TestCase): # Remove color code escape sequences output = re.sub(r'\x1B\[[0-?]*[ -/]*[@-~]', '', str(output)) + if ('Error loading client' in output or + 'Unexpected error' in output): + raise Exception(output) + remarks = [] lines = output.split('\n') + success = False + failure = False i = 0 while i < len(lines): - if 'Error' in lines[i]: + if '[Fail]' in lines[i] or 'Failures:' in lines[i]: self.__logger.error(lines[i]) - if '[k8s.io]' in lines[i]: - if i != 0 and 'seconds' in lines[i - 1]: - self.__logger.debug(lines[i - 1]) - while lines[i] != '-' * len(lines[i]): + if re.search(r'\[(.)*[0-9]+ seconds\]', lines[i]): + self.__logger.debug(lines[i]) + i = i + 1 + while i < len(lines) and lines[i] != '-' * len(lines[i]): if lines[i].startswith('STEP:') or ('INFO:' in lines[i]): break self.__logger.debug(lines[i]) i = i + 1 - + if i >= len(lines): + break success = 'SUCCESS!' in lines[i] failure = 'FAIL!' in lines[i] if success or failure: diff --git a/functest_kubernetes/test_k8stest.py b/functest_kubernetes/test_k8stest.py index 9db14d5a..c9faf35d 100644 --- a/functest_kubernetes/test_k8stest.py +++ b/functest_kubernetes/test_k8stest.py @@ -77,8 +77,9 @@ class K8sTests(unittest.TestCase): attrs = {'stdout.read.return_value': 'Error loading client'} mock_stdout.configure_mock(**attrs) mock_popen.return_value = mock_stdout - self.k8stesting.run_kubetest() - mock_logger.error.assert_called_with("Error loading client") + self.k8stesting.run() + mock_logger.exception.assert_called_with( + "Error with running kubetest:") @mock.patch('functest_kubernetes.k8stest.os.path.isfile') @mock.patch('functest_kubernetes.k8stest.subprocess.Popen') |