Clean-up of resources created in ODU workflows
Change-Id: Ib2051d5844841d6469a4dc3e854ff2ef88a36a87
Signed-off-by: garciadeblas <gerardo.garciadeblas@telefonica.com>
diff --git a/osm_lcm/odu_libs/cluster_mgmt.py b/osm_lcm/odu_libs/cluster_mgmt.py
index 8caed34..719c7a8 100644
--- a/osm_lcm/odu_libs/cluster_mgmt.py
+++ b/osm_lcm/odu_libs/cluster_mgmt.py
@@ -136,27 +136,6 @@
)
return workflow_name
- # self.logger.info(f"Deleting secret {secret_name} in namespace {secret_namespace} ...")
- # self._kubectl.delete_secret(name=secret_name, namespace=secret_namespace)
- # self.logger.info("DONE")
-
- # self.logger.info(f"Listing secrets in namespace {secret_namespace} ...")
- # secret_list = self._kubectl.get_secrets(secret_namespace)
- # # print(secret_list)
- # for item in secret_list:
- # print(item.metadata.name)
- # self.logger.info("DONE")
-
- # self.logger.info(f"Deleting secrets in namespace {secret_namespace} ...")
- # for item in secret_list:
- # print(f"Deleting {item.metadata.name} ...")
- # self._kubectl.delete_secret(
- # name=item.metadata.name,
- # namespace=secret_namespace,
- # )
- # self.logger.info("DELETED")
- # self.logger.info("DONE")
-
async def update_cluster(self, op_id, op_params, content):
self.logger.info("Update cluster eks workflow Enter")
@@ -338,6 +317,30 @@
return False, message
+async def clean_items_cluster_create(self, op_id, op_params, content):
+ self.logger.info("Clean items cluster_create Enter")
+ self.logger.info(f"Operation {op_id}. Params: {op_params}. Content: {content}")
+ items = {
+ "secrets": [
+ {
+ "name": f"secret-age-{content['cluster']['git_name'].lower()}",
+ "namespace": "osm-workflows",
+ }
+ ]
+ }
+ try:
+ await self.clean_items(items)
+ return True, "OK"
+ except Exception as e:
+ return False, f"Error while cleaning items: {e}"
+
+
+async def clean_items_cluster_update(self, op_id, op_params, content):
+ self.logger.info("Clean items cluster_update Enter")
+ self.logger.info(f"Operation {op_id}. Params: {op_params}. Content: {content}")
+ return await self.clean_items_cluster_create(op_id, op_params, content)
+
+
async def check_create_cluster(self, op_id, op_params, content):
self.logger.info(f"Operation {op_id}. Params: {op_params}. Content: {content}")
return True, "OK"