X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FN2VC.git;a=blobdiff_plain;f=n2vc%2Flibjuju.py;h=cb24a3e055cb3156075f6a91a5e26008055ffb20;hp=be16e2a8481dac8366fd6b6fa80f3dedc84c4b57;hb=810459632a4fb28e1bde897aaef8775cba342b4b;hpb=2cf8b2e0cd32ab2e8f3913ae9c5e156710465240 diff --git a/n2vc/libjuju.py b/n2vc/libjuju.py index be16e2a..cb24a3e 100644 --- a/n2vc/libjuju.py +++ b/n2vc/libjuju.py @@ -29,6 +29,8 @@ from n2vc.n2vc_conn import N2VCConnector from n2vc.exceptions import ( JujuMachineNotFound, JujuApplicationNotFound, + JujuLeaderUnitNotFound, + JujuActionNotFound, JujuModelAlreadyExists, JujuControllerFailedConnecting, JujuApplicationExists, @@ -298,7 +300,7 @@ class Libjuju: machine_id, model_name ) ) - machine = model.machines[machine_id] + machine = machines[machine_id] else: raise JujuMachineNotFound("Machine {} not found".format(machine_id)) @@ -406,7 +408,7 @@ class Libjuju: connection=connection, nonce=params.nonce, machine_id=machine_id, - api=self.api_proxy, + proxy=self.api_proxy, ) ) @@ -570,7 +572,6 @@ class Libjuju: :param: application_name: Application name :param: model_name: Model name - :param: cloud_name: Cloud name :param: action_name: Name of the action :param: db_dict: Dictionary with data of the DB to write the updates :param: progress_timeout: Maximum time between two updates in the model @@ -601,12 +602,12 @@ class Libjuju: if await u.is_leader_from_status(): unit = u if unit is None: - raise Exception("Cannot execute action: leader unit not found") + raise JujuLeaderUnitNotFound("Cannot execute action: leader unit not found") actions = await application.get_actions() if action_name not in actions: - raise Exception( + raise JujuActionNotFound( "Action {} not in available actions".format(action_name) ) @@ -637,8 +638,6 @@ class Libjuju: action_name, action.status, application_name, model_name ) ) - except Exception as e: - raise e finally: await self.disconnect_model(model) await self.disconnect_controller(controller) @@ -819,7 +818,7 @@ class Libjuju: """ machines = await model.get_machines() if machine_id in machines: - machine = model.machines[machine_id] + machine = machines[machine_id] await machine.destroy(force=True) # max timeout end = time.time() + total_timeout