X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FN2VC.git;a=blobdiff_plain;f=n2vc%2Fn2vc_juju_conn.py;h=690d3bee57cc98ae451e7f3c414849068022792e;hp=ed1250d822b638b252333437705b95f217d82637;hb=2c791b34626ff76ab1886a110599998f9de0df80;hpb=b95133489d1cd16e1692085b1193d24d52c858fc diff --git a/n2vc/n2vc_juju_conn.py b/n2vc/n2vc_juju_conn.py index ed1250d..690d3be 100644 --- a/n2vc/n2vc_juju_conn.py +++ b/n2vc/n2vc_juju_conn.py @@ -166,15 +166,16 @@ class N2VCJujuConnector(N2VCConnector): if self.ca_cert: self.ca_cert = base64_to_cacert(vca_config["ca_cert"]) - if "api_proxy" in vca_config: + if "api_proxy" in vca_config and vca_config["api_proxy"] != "": self.api_proxy = vca_config["api_proxy"] self.log.debug( "api_proxy for native charms configured: {}".format(self.api_proxy) ) else: self.warning( - "api_proxy is not configured. Support for native charms is disabled" + "api_proxy is not configured" ) + self.api_proxy = None if "enable_os_upgrade" in vca_config: self.enable_os_upgrade = vca_config["enable_os_upgrade"] @@ -241,7 +242,7 @@ class N2VCJujuConnector(N2VCConnector): models = await self.libjuju.list_models(contains=ns_id) for m in models: - status[m] = self.libjuju.get_model_status(m) + status[m] = await self.libjuju.get_model_status(m) if yaml_format: return obj_to_yaml(status) @@ -376,10 +377,6 @@ class N2VCJujuConnector(N2VCConnector): # register machine on juju try: - if not self.api_proxy: - msg = "Cannot provision machine: api_proxy is not defined" - self.log.error(msg=msg) - raise N2VCException(message=msg) if not await self.libjuju.model_exists(model_name): await self.libjuju.add_model(model_name, cloud_name=self.cloud) machine_id = await self.libjuju.provision_machine( @@ -577,6 +574,9 @@ class N2VCJujuConnector(N2VCConnector): application_name=application_name, machine_id="k8s", ) + + self._write_ee_id_db(db_dict=db_dict, ee_id=ee_id) + return ee_id async def get_ee_ssh_public__key( @@ -1184,7 +1184,7 @@ class N2VCJujuConnector(N2VCConnector): connection=connection, nonce=params.nonce, machine_id=machine_id, - api=self.api_proxy, + proxy=self.api_proxy, ) )