"app_profiles": "k8sapp",
"resource_profiles": "k8sresource",
}
+ self.logger.info("the db_cluster is :{}".format(db_cluster))
for profile_type in profiles:
profile_id = db_cluster[profile_type]
self.logger.info("profile id is : {}".format(profile_id))
db_profile["resourceState"] = db_cluster["resourceState"]
db_profile["operatingState"] = db_cluster["operatingState"]
db_profile["age_pubkey"] = db_cluster["age_pubkey"]
- db_profile["age_privkey"] = db_profile["age_privkey"]
+ db_profile["age_privkey"] = db_cluster["age_privkey"]
db_profile = self.update_operation_history(
db_profile, op_id, workflow_status, resource_status
)
return
elif command == "upgrade" or command == "scale" or command == "update":
# db_vim = self.db.get_one("vim_accounts", {"_id": db_cluster["vim_account"]})
+ """
db_vim = self.db.get_one(
"vim_accounts", {"name": db_cluster["vim_account"]}
)
db_content["vim_account"] = db_vim
+ """
task = asyncio.ensure_future(
self.cluster.update(op_id, op_params, db_content)
)