Update cluster configuration to support feature 11055
Change-Id: I350be30250ac87aebe83f3284e2dab859df254f8
Signed-off-by: rshri <shrinithi.r@tataelxsi.co.in>
diff --git a/osm_lcm/odu_workflows.py b/osm_lcm/odu_workflows.py
index 0244567..730acfe 100644
--- a/osm_lcm/odu_workflows.py
+++ b/osm_lcm/odu_workflows.py
@@ -192,6 +192,8 @@
render_yaml_template = odu_render.render_yaml_template
create_secret = odu_common.create_secret
delete_secret = odu_common.delete_secret
+ create_configmap = odu_common.create_configmap
+ delete_configmap = odu_common.delete_configmap
async def launch_workflow(self, key, op_id, op_params, content):
self.logger.info(
@@ -268,3 +270,28 @@
f"Testing kubectl configuration Host: {self._kubectl.configuration.host}"
)
await self._kubectl.delete_pvc(name, namespace)
+ # Delete configmaps
+ for configmap in items.get("configmaps", []):
+ name = configmap["name"]
+ namespace = configmap["namespace"]
+ self.logger.info(f"Deleting configmap {name} in namespace {namespace}")
+ self.logger.debug(f"Testing kubectl: {self._kubectl}")
+ self.logger.debug(
+ f"Testing kubectl configuration: {self._kubectl.configuration}"
+ )
+ self.logger.debug(
+ f"Testing kubectl configuration Host: {self._kubectl.configuration.host}"
+ )
+ self.delete_configmap(name, namespace)
+
+ async def list_object(self, api_group, api_plural, api_version):
+ self.logger.info(
+ f"Api group: {api_group} Api plural: {api_plural} Api version: {api_version}"
+ )
+ generic_object = await self._kubectl.list_generic_object(
+ api_group=api_group,
+ api_plural=api_plural,
+ api_version=api_version,
+ namespace="",
+ )
+ return generic_object