commit 8424d1b1c8fc8e54b2376cc864c6a27ab0ea1e02
author garciadeblas <gerardo.garciadeblas@telefonica.com> Thu Oct 24 12:52:11 2024 +0200
committer garciadeblas <gerardo.garciadeblas@telefonica.com> Fri Mar 21 10:13:20 2025 +0100
tree cede0972e70ba55f0bf9845de877ecf312427834
parent b14d02e99bba3b0475d462f2470cfbf4e47cad98

Update list of checks for AWS and GCP cluster creation

Change-Id: I7ae53a6098b10cea1deeb93979dfee165fbb2d84
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>

osm_lcm/odu_libs/workflows.py

diff --git a/osm_lcm/odu_libs/workflows.py b/osm_lcm/odu_libs/workflows.py
index a95e982..61b9353 100644
--- a/osm_lcm/odu_libs/workflows.py
+++ b/osm_lcm/odu_libs/workflows.py
@@ -18,6 +18,7 @@
 
 import asyncio
 import traceback
+import yaml
 from math import ceil
 
 
@@ -38,7 +39,7 @@
 async def readiness_loop(self, item, name, namespace, flag, timeout):
     self.logger.info("readiness_loop Enter")
     self.logger.info(
-        f"{item} {name}. Namespace: {namespace}. Flag: {flag}. Timeout: {timeout}"
+        f"{item} {name}. Namespace: '{namespace}'. Flag: {flag}. Timeout: {timeout}"
     )
     item_api_map = {
         "workflow": {
@@ -66,6 +67,16 @@
             "api_plural": "clusters",
             "api_version": "v1beta2",
         },
+        "nodepool_aws": {
+            "api_group": "eks.aws.upbound.io",
+            "api_plural": "nodegroups",
+            "api_version": "v1beta1",
+        },
+        "nodepool_gcp": {
+            "api_group": "container.gcp.upbound.io",
+            "api_plural": "nodepools",
+            "api_version": "v1beta2",
+        },
     }
     counter = 1
     retry_time = self._odu_checkloop_retry_time
@@ -83,9 +94,12 @@
             name=name,
         )
         if generic_object:
-            # self.logger.debug(f"{yaml.safe_dump(generic_object)}")
+            self.logger.debug(f"{yaml.safe_dump(generic_object)}")
             conditions = generic_object.get("status", {}).get("conditions", [])
         else:
+            self.logger.debug(
+                f"Could not find {api_plural}. Name: {name}. Namespace: '{namespace}'. API: {api_group}/{api_version}"
+            )
             conditions = []
         self.logger.info(
             f"Iteration {counter}/{max_iterations}. {item} status conditions: {conditions}"