from osm_lcm import ROclient
from osm_lcm.lcm_utils import LcmException, LcmBase, deep_get
from n2vc.k8s_helm_conn import K8sHelmConnector
+from n2vc.k8s_helm3_conn import K8sHelm3Connector
from n2vc.k8s_juju_conn import K8sJujuConnector
from n2vc.exceptions import K8sException, N2VCException
from osm_common.dbbase import DbException
operation_state = 'COMPLETED'
operation_details = 'Done'
- # await asyncio.sleep(15) # TODO remove. This is for test
self.logger.debug(logging_text + "Exit Ok VIM account created at RO_vim_account_id={}".format(desc["uuid"]))
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
vim_RO.pop("vim_password", None)
if RO_sdn_id:
vim_RO["config"]["sdn-controller"] = RO_sdn_id
- # TODO make a deep update of sdn-port-mapping
+ # TODO make a deep update of sdn-port-mapping
if vim_RO:
await RO.edit("vim", RO_vim_id, descriptor=vim_RO)
self.logger.debug(logging_text + "Exit Ok RO_vim_id={}".format(RO_vim_id))
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
try:
# wait for any previous tasks in process
await self.lcm_tasks.waitfor_related_HA('vim', 'delete', op_id)
-
- db_vim = self.db.get_one("vim_accounts", {"_id": vim_id})
- if db_vim.get("_admin") and db_vim["_admin"].get("deployed") and db_vim["_admin"]["deployed"].get("RO"):
- RO_vim_id = db_vim["_admin"]["deployed"]["RO"]
- RO = ROclient.ROClient(self.loop, **self.ro_config)
- step = "Detaching vim from RO tenant"
- try:
- await RO.detach("vim_account", RO_vim_id)
- except ROclient.ROClientException as e:
- if e.http_code == 404: # not found
- self.logger.debug(logging_text + "RO_vim_id={} already detached".format(RO_vim_id))
- else:
- raise
-
- step = "Deleting vim from RO"
- try:
- await RO.delete("vim", RO_vim_id)
- except ROclient.ROClientException as e:
- if e.http_code == 404: # not found
- self.logger.debug(logging_text + "RO_vim_id={} already deleted".format(RO_vim_id))
- else:
- raise
- else:
- # nothing to delete
- self.logger.error(logging_text + "Nothing to remove at RO")
+ if not self.ro_config.get("ng"):
+ db_vim = self.db.get_one("vim_accounts", {"_id": vim_id})
+ if db_vim.get("_admin") and db_vim["_admin"].get("deployed") and db_vim["_admin"]["deployed"].get("RO"):
+ RO_vim_id = db_vim["_admin"]["deployed"]["RO"]
+ RO = ROclient.ROClient(self.loop, **self.ro_config)
+ step = "Detaching vim from RO tenant"
+ try:
+ await RO.detach("vim_account", RO_vim_id)
+ except ROclient.ROClientException as e:
+ if e.http_code == 404: # not found
+ self.logger.debug(logging_text + "RO_vim_id={} already detached".format(RO_vim_id))
+ else:
+ raise
+
+ step = "Deleting vim from RO"
+ try:
+ await RO.delete("vim", RO_vim_id)
+ except ROclient.ROClientException as e:
+ if e.http_code == 404: # not found
+ self.logger.debug(logging_text + "RO_vim_id={} already deleted".format(RO_vim_id))
+ else:
+ raise
+ else:
+ # nothing to delete
+ self.logger.debug(logging_text + "Nothing to remove at RO")
self.db.del_one("vim_accounts", {"_id": vim_id})
db_vim = None
self.logger.debug(logging_text + "Exit Ok")
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
self.logger.debug(logging_text + "Exit Ok WIM account created at RO_wim_account_id={}".format(desc["uuid"]))
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
self.logger.debug(logging_text + "Exit Ok RO_wim_id={}".format(RO_wim_id))
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
self.logger.debug(logging_text + "Exit Ok")
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
operation_details = 'Done'
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
self.logger.debug(logging_text + "Exit Ok RO_sdn_id={}".format(RO_sdn_id))
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
self.logger.debug("sdn_delete task sdn_id={} Exit Ok".format(sdn_id))
return
- except (ROclient.ROClientException, DbException) as e:
+ except (ROclient.ROClientException, DbException, asyncio.CancelledError) as e:
self.logger.error(logging_text + "Exit Exception {}".format(e))
exc = e
except Exception as e:
class K8sClusterLcm(LcmBase):
- timeout_create = 600
+ timeout_create = 300
def __init__(self, db, msg, fs, lcm_tasks, config, loop):
"""
self.fs = fs
self.db = db
- self.helm_k8scluster = K8sHelmConnector(
+ self.helm2_k8scluster = K8sHelmConnector(
kubectl_command=self.vca_config.get("kubectlpath"),
helm_command=self.vca_config.get("helmpath"),
fs=self.fs,
on_update_db=None
)
+ self.helm3_k8scluster = K8sHelm3Connector(
+ kubectl_command=self.vca_config.get("kubectlpath"),
+ helm_command=self.vca_config.get("helm3path"),
+ fs=self.fs,
+ log=self.logger,
+ db=self.db,
+ on_update_db=None
+ )
+
self.juju_k8scluster = K8sJujuConnector(
kubectl_command=self.vca_config.get("kubectlpath"),
juju_command=self.vca_config.get("jujupath"),
fs=self.fs,
log=self.logger,
db=self.db,
- on_update_db=None
+ loop=self.loop,
+ on_update_db=None,
+ vca_config=self.vca_config,
)
self.k8s_map = {
- "helm-chart": self.helm_k8scluster,
+ "helm-chart": self.helm2_k8scluster,
+ "helm-chart-v3": self.helm3_k8scluster,
"juju-bundle": self.juju_k8scluster,
}
task2name = {}
init_target = deep_get(db_k8scluster, ("_admin", "init"))
step = "Launching k8scluster init tasks"
- for task_name in ("helm-chart", "juju-bundle"):
+ for task_name in ("helm-chart", "juju-bundle", "helm-chart-v3"):
if init_target and task_name not in init_target:
continue
task = asyncio.ensure_future(self.k8s_map[task_name].init_env(k8s_credentials,
error_text_list.append("Failing init {}: {}".format(task_name, exc))
db_k8scluster_update["_admin.{}.error_msg".format(task_name)] = str(exc)
db_k8scluster_update["_admin.{}.id".format(task_name)] = None
+ db_k8scluster_update["_admin.{}.operationalState".format(task_name)] = "ERROR"
self.logger.error(logging_text + "{} init fail: {}".format(task_name, exc),
exc_info=not isinstance(exc, (N2VCException, str)))
else:
db_k8scluster_update["_admin.{}.error_msg".format(task_name)] = None
db_k8scluster_update["_admin.{}.id".format(task_name)] = k8s_id
db_k8scluster_update["_admin.{}.created".format(task_name)] = uninstall_sw
- db_k8scluster_update["_admin.operationalState"] = "ENABLED"
+ db_k8scluster_update["_admin.{}.operationalState".format(task_name)] = "ENABLED"
# update database
step = "Updating database for " + task_name
self.update_db_2("k8sclusters", k8scluster_id, db_k8scluster_update)
- if not tasks_name_ok:
+ if tasks_name_ok:
+ operation_details = "ready for " + ", ".join(tasks_name_ok)
+ operation_state = "COMPLETED"
+ db_k8scluster_update["_admin.operationalState"] = "ENABLED" if not error_text_list else "DEGRADED"
+ operation_details += "; " + ";".join(error_text_list)
+ else:
db_k8scluster_update["_admin.operationalState"] = "ERROR"
operation_state = "FAILED"
- else:
- db_k8scluster_update["_admin.detailed-status"] = "ready for " + ", ;".join(tasks_name_ok)
- operation_state = "COMPLETED"
- operation_details = db_k8scluster_update["_admin.detailed-status"] = ";".join(error_text_list)
+ operation_details = ";".join(error_text_list)
+ db_k8scluster_update["_admin.detailed-status"] = operation_details
self.logger.debug(logging_text + "Done. Result: " + operation_state)
exc = None
except Exception as e:
- self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
+ if isinstance(e, (LcmException, DbException, K8sException, N2VCException, asyncio.CancelledError)):
+ self.logger.error(logging_text + "Exit Exception {}".format(e))
+ else:
+ self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
exc = e
finally:
if exc and db_k8scluster:
self.logger.debug(logging_text + step)
db_k8scluster = self.db.get_one("k8sclusters", {"_id": k8scluster_id})
k8s_hc_id = deep_get(db_k8scluster, ("_admin", "helm-chart", "id"))
+ k8s_h3c_id = deep_get(db_k8scluster, ("_admin", "helm-chart-v3", "id"))
k8s_jb_id = deep_get(db_k8scluster, ("_admin", "juju-bundle", "id"))
cluster_removed = True
uninstall_sw = deep_get(db_k8scluster, ("_admin", "juju-bundle", "created")) or False
cluster_removed = await self.juju_k8scluster.reset(cluster_uuid=k8s_jb_id, uninstall_sw=uninstall_sw)
db_k8scluster_update["_admin.juju-bundle.id"] = None
+ db_k8scluster_update["_admin.juju-bundle.operationalState"] = "DISABLED"
if k8s_hc_id:
step = "Removing helm-chart '{}'".format(k8s_hc_id)
uninstall_sw = deep_get(db_k8scluster, ("_admin", "helm-chart", "created")) or False
- cluster_removed = await self.helm_k8scluster.reset(cluster_uuid=k8s_hc_id, uninstall_sw=uninstall_sw)
+ cluster_removed = await self.helm2_k8scluster.reset(cluster_uuid=k8s_hc_id, uninstall_sw=uninstall_sw)
db_k8scluster_update["_admin.helm-chart.id"] = None
+ db_k8scluster_update["_admin.helm-chart.operationalState"] = "DISABLED"
+
+ if k8s_h3c_id:
+ step = "Removing helm-chart-v3 '{}'".format(k8s_hc_id)
+ uninstall_sw = deep_get(db_k8scluster, ("_admin", "helm-chart-v3", "created")) or False
+ cluster_removed = await self.helm3_k8scluster.reset(cluster_uuid=k8s_hc_id, uninstall_sw=uninstall_sw)
+ db_k8scluster_update["_admin.helm-chart-v3.id"] = None
+ db_k8scluster_update["_admin.helm-chart-v3.operationalState"] = "DISABLED"
# Try to remove from cluster_inserted to clean old versions
if k8s_hc_id and cluster_removed:
self.logger.debug(logging_text + "Done")
except Exception as e:
- if isinstance(e, (LcmException, DbException, K8sException, N2VCException)):
+ if isinstance(e, (LcmException, DbException, K8sException, N2VCException, asyncio.CancelledError)):
self.logger.error(logging_text + "Exit Exception {}".format(e))
else:
self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
self.fs = fs
self.db = db
- self.k8srepo = K8sHelmConnector(
- kubectl_command=self.vca_config.get("kubectlpath"),
- helm_command=self.vca_config.get("helmpath"),
- fs=self.fs,
- log=self.logger,
- db=self.db,
- on_update_db=None
- )
-
super().__init__(db, msg, fs, self.logger)
async def create(self, k8srepo_content, order_id):
db_k8srepo = self.db.get_one("k8srepos", {"_id": k8srepo_id})
db_k8srepo_update["_admin.operationalState"] = "ENABLED"
except Exception as e:
- self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
+ self.logger.error(logging_text + "Exit Exception {}".format(e),
+ exc_info=not isinstance(e, (LcmException, DbException, K8sException, N2VCException,
+ asyncio.CancelledError)))
exc = e
finally:
if exc and db_k8srepo:
db_k8srepo = self.db.get_one("k8srepos", {"_id": k8srepo_id})
except Exception as e:
- self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
+ self.logger.error(logging_text + "Exit Exception {}".format(e),
+ exc_info=not isinstance(e, (LcmException, DbException, K8sException, N2VCException,
+ asyncio.CancelledError)))
exc = e
finally:
if exc and db_k8srepo:
projects / osm / LCM.git / blobdiff