X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FN2VC.git;a=blobdiff_plain;f=n2vc%2Fn2vc_juju_conn.py;h=9230e6d8b1e0dc01842a3066258d1f5bf03e7d7b;hp=c6c98901d85ef5cb89cd4120766d232bdc92e71a;hb=refs%2Fchanges%2F27%2F8727%2F6;hpb=f9bed35a0acf26a93eb2f6d0f146fa71579af74a diff --git a/n2vc/n2vc_juju_conn.py b/n2vc/n2vc_juju_conn.py index c6c9890..9230e6d 100644 --- a/n2vc/n2vc_juju_conn.py +++ b/n2vc/n2vc_juju_conn.py @@ -168,6 +168,7 @@ class N2VCJujuConnector(N2VCConnector): else: self.apt_mirror = None + self.cloud = vca_config.get('cloud') self.log.debug('Arguments have been checked') # juju data @@ -1024,7 +1025,10 @@ class N2VCJujuConnector(N2VCConnector): application = await self._juju_get_application(model_name=model_name, application_name=application_name) - unit = application.units[0] + unit = None + for u in application.units: + if await u.is_leader_from_status(): + unit = u if unit is not None: actions = await application.get_actions() if action_name in actions: @@ -1166,7 +1170,8 @@ class N2VCJujuConnector(N2VCConnector): model = await self.controller.add_model( model_name=model_name, - config=config_dict + config=config_dict, + cloud_name=self.cloud, ) self.log.info('New model created, name={}'.format(model_name)) else: