unset = {'_admin.helm_charts_added.' + item: None for item in del_repo_list}
updated = {'_admin.helm_charts_added.' +
item: name for item, name in added_repo_dict.items()}
- self.logger.debug("repos synchronized, to_delete: {}, to_add: {}".
+ self.logger.debug(logging_text + "repos synchronized, to_delete: {}, to_add: {}".
format(del_repo_list, added_repo_dict))
self.db.set_one("k8sclusters", {"_id": kdur["k8s-cluster"]["id"]},
updated, unset=unset)
- updated_cluster_list.append(cluster_uuid)
+ updated_cluster_list.append(cluster_uuid)
except LcmException as e:
error_text = str(e)
detailed_status=detailed_status_HA)
except DbException as e:
self.logger.error(logging_text + "Cannot update database: {}".format(e))
- self.lcm_tasks.remove("k8sclusters", k8scluster_id, order_id)
+ self.lcm_tasks.remove("k8scluster", k8scluster_id, order_id)
async def delete(self, k8scluster_content, order_id):
# raise Exception("K8scluster was not properly removed")
except Exception as e:
- self.logger.critical(logging_text + "Exit Exception {}".format(e), exc_info=True)
+ if isinstance(e, LcmException, DbException):
+ 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:
detailed_status=detailed_status_HA)
except DbException as e:
self.logger.error(logging_text + "Cannot update database: {}".format(e))
- self.lcm_tasks.remove("k8sclusters", k8scluster_id, order_id)
+ self.lcm_tasks.remove("k8scluster", k8scluster_id, order_id)
class K8sRepoLcm(LcmBase):