diff options
author | Lukasz Rajewski <lukasz.rajewski@t-mobile.pl> | 2023-05-23 11:56:25 +0000 |
---|---|---|
committer | Lukasz Rajewski <lukasz.rajewski@t-mobile.pl> | 2023-05-23 11:56:25 +0000 |
commit | b766e7663a66ad93f3495bcec0769fe0a5e910c6 (patch) | |
tree | ba6d326851c322e2f78ad466e2edb0ee66cda6b9 /src/onaptests/steps | |
parent | 6dc4f7277cd749ebe278ae0838c34ff3a2481ef9 (diff) |
Fix VES client simulator image and pod verification method
Issue-ID: TEST-397
Signed-off-by: Lukasz Rajewski <lukasz.rajewski@t-mobile.pl>
Change-Id: Iaabd13e0eed2f7a0714e8baf6f5eaf01da599ebd
Diffstat (limited to 'src/onaptests/steps')
-rw-r--r-- | src/onaptests/steps/simulator/pnf_simulator_cnf/pnf_register.py | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/onaptests/steps/simulator/pnf_simulator_cnf/pnf_register.py b/src/onaptests/steps/simulator/pnf_simulator_cnf/pnf_register.py index 3180733..0e6e001 100644 --- a/src/onaptests/steps/simulator/pnf_simulator_cnf/pnf_register.py +++ b/src/onaptests/steps/simulator/pnf_simulator_cnf/pnf_register.py @@ -49,6 +49,7 @@ class PnfSimulatorCnfRegisterStep(BaseStep): config.load_kube_config(settings.K8S_CONFIG) k8s_client: "CoreV1API" = client.CoreV1Api() k8s_watch: "Watch" = watch.Watch() + status = False try: for event in k8s_watch.stream(k8s_client.list_namespaced_pod, namespace=settings.K8S_ADDITIONAL_RESOURCES_NAMESPACE, @@ -57,8 +58,9 @@ class PnfSimulatorCnfRegisterStep(BaseStep): if not event["object"].status.phase in ["Pending", "Running"]: # Invalid pod state return False - return event["object"].status.phase == "Running" - return False + if event["object"].status.phase == "Running": + return True + return status except urllib3.exceptions.HTTPError: self._logger.error("Can't connect with k8s") raise OnapTestException @@ -91,8 +93,9 @@ class PnfSimulatorCnfRegisterStep(BaseStep): def execute(self) -> None: """Send PNF registration event.""" super().execute() - if not self.is_pnf_pod_running(): - EnvironmentPreparationException("PNF simulator is not running") + status = self.is_pnf_pod_running() + if not status: + raise EnvironmentPreparationException("PNF simulator is not running") time.sleep(settings.PNF_WAIT_TIME) # Let's still wait for PNF simulator to make sure it's initialized ves_proto, ves_ip, ves_port = self.get_ves_protocol_ip_and_port() registration_number: int = 0 |