self.log.error(error_msg)
raise K8sException(message=error_msg)
return True
async def get_scale_count(
self.log.error(error_msg)
raise K8sException(message=error_msg)
return True
async def get_scale_count(
return len(status.applications[resource_name].units)
except Exception as e:
error_msg = "Error getting scale count from application {} in kdu instance {}: {}".format(
return len(status.applications[resource_name].units)
except Exception as e:
error_msg = "Error getting scale count from application {} in kdu instance {}: {}".format(
- await self.on_update_db(cluster_uuid, kdu_instance, filter=db_dict["filter"])
+ await self.on_update_db(
+ cluster_uuid, kdu_instance, filter=db_dict["filter"]
+ )
- vcastatus[model_name]["applications"][application]["actions"] = \
- await libjuju.get_actions(application, kdu_instance)
+ vcastatus[model_name]["applications"][application][
+ "actions"
+ ] = await libjuju.get_actions(application, kdu_instance)
- vcastatus[model_name]["applications"][application]["configs"] = \
- await libjuju.get_application_configs(kdu_instance, application)
+ vcastatus[model_name]["applications"][application][
+ "configs"
+ ] = await libjuju.get_application_configs(kdu_instance, application)