self.logger.info("cluster Create Enter")
db_cluster = content["cluster"]
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_cluster", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("cluster delete Enter")
db_cluster = content["cluster"]
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_cluster", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("profile type is : {}".format(profile_type))
self.logger.info("profile id is : {}".format(profile_id))
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"attach_profile_to_cluster", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("profile type is : {}".format(profile_type))
self.logger.info("profile id is : {}".format(profile_id))
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"detach_profile_from_cluster", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("cluster register enter")
db_cluster = content["cluster"]
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"register_cluster", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("db_cluster is : {}".format(db_cluster))
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"deregister_cluster", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("Cluster update Enter")
db_cluster = content["cluster"]
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"update_cluster", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def add(self, op_id, op_params, content):
self.logger.info("Cloud Credentials create")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_cloud_credentials", op_id, op_params, content
)
return
async def edit(self, op_id, op_params, content):
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"update_cloud_credentials", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def remove(self, op_id, op_params, content):
self.logger.info("Cloud Credentials delete")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_cloud_credentials", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def create(self, op_id, op_params, content):
self.logger.info("App Create Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
async def delete(self, op_id, op_params, content):
self.logger.info("App delete Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
async def create(self, op_id, op_params, content):
self.logger.info("Resource Create Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("Resource delete Enter")
content = self.db.get_one("k8sresource", {"_id": content["_id"]})
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
async def create(self, op_id, op_params, content):
self.logger.info("Infra controller Create Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
async def delete(self, op_id, op_params, content):
self.logger.info("Infra controller delete Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
async def create(self, op_id, op_params, content):
self.logger.info("Infra config Create Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
async def delete(self, op_id, op_params, content):
self.logger.info("Infra config delete Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_profile", op_id, op_params, content
)
self.logger.info("workflow_name is :{}".format(workflow_name))
self.logger.info("OKA Create Enter")
db_content = content
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_oka", op_id, op_params, db_content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
self.logger.info("OKA Edit Enter")
db_content = content
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"update_oka", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
self.logger.info("OKA delete Enter")
db_content = content
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_oka", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def create(self, op_id, op_params, content):
self.logger.info("ksu Create Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"create_ksus", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def edit(self, op_id, op_params, content):
self.logger.info("ksu edit Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"update_ksus", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def delete(self, op_id, op_params, content):
self.logger.info("ksu delete Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"delete_ksus", op_id, op_params, content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def clone(self, op_id, op_params, db_content):
self.logger.info("ksu clone Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"clone_ksus", op_id, op_params, db_content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(
async def move(self, op_id, op_params, db_content):
self.logger.info("ksu move Enter")
- workflow_name = await self.odu.launch_workflow(
+ _, workflow_name = await self.odu.launch_workflow(
"move_ksus", op_id, op_params, db_content
)
workflow_status, workflow_msg = await self.odu.check_workflow_status(