diff --git a/kuryr_tempest_plugin/tests/scenario/base.py b/kuryr_tempest_plugin/tests/scenario/base.py index ecf0d24a..f2018793 100644 --- a/kuryr_tempest_plugin/tests/scenario/base.py +++ b/kuryr_tempest_plugin/tests/scenario/base.py @@ -127,18 +127,30 @@ class BaseKuryrScenarioTest(manager.NetworkScenarioTest): return pod.status.phase @classmethod - def get_pod_readiness(cls, pod_name, namespace="default", - container_name=None): + def get_readiness_state(cls, pod_name, namespace="default", + container_name=None): pod_list = cls.k8s_client.CoreV1Api().list_namespaced_pod( namespace=namespace) for pod in pod_list.items: if pod.metadata.name == pod_name: - for container in pod.status.containerStatuses: - if container_name: + if container_name: + for container in pod.status.container_statuses: if container.name == container_name: return container.ready - else: - return container.ready + else: + for condition in pod.status.conditions: + if condition.type == 'Ready': + return condition.status + + @classmethod + def get_pod_readiness(cls, pod_name, namespace="default"): + return cls.get_readiness_state(pod_name, namespace=namespace) + + @classmethod + def get_container_readiness(cls, pod_name, namespace="default", + container_name=None): + return cls.get_readiness_state(pod_name, namespace=namespace, + container_name=container_name) def get_pod_port(self, pod_name, namespace="default"): pod = self.k8s_client.CoreV1Api().read_namespaced_pod_status( diff --git a/kuryr_tempest_plugin/tests/scenario/test_port_pool.py b/kuryr_tempest_plugin/tests/scenario/test_port_pool.py index 70d5fb0b..45fc0803 100644 --- a/kuryr_tempest_plugin/tests/scenario/test_port_pool.py +++ b/kuryr_tempest_plugin/tests/scenario/test_port_pool.py @@ -94,8 +94,7 @@ class TestPortPoolScenario(base.BaseKuryrScenarioTest): pod_readiness_retries = 30 while not self.get_pod_readiness( kube_system_pod, - namespace=CONF.kuryr_kubernetes.kube_system_namespace, - container_name='controller'): + namespace=CONF.kuryr_kubernetes.kube_system_namespace): time.sleep(1) pod_readiness_retries -= 1 if pod_readiness_retries == 0: