X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=juju%2Funit.py;h=78acaff44587ad17abd1a1ced2586a649b44be9a;hb=5acba37aaefa55fab65eb3ca8b5a5fcf24606a2a;hp=4d75484ccf639fb54ba592b6cca4a47d49e3ae99;hpb=fe2d2f1a5ef2453359858481929a2526ea1a3c5c;p=osm%2FN2VC.git diff --git a/juju/unit.py b/juju/unit.py index 4d75484..78acaff 100644 --- a/juju/unit.py +++ b/juju/unit.py @@ -1,4 +1,9 @@ +import logging + from . import model +from .client import client + +log = logging.getLogger(__name__) class Unit(model.ModelEntity): @@ -18,11 +23,17 @@ class Unit(model.ModelEntity): """ pass - def destroy(self): + async def destroy(self): """Destroy this unit. """ - pass + app_facade = client.ApplicationFacade() + app_facade.connect(self.connection) + + log.debug( + 'Destroying %s', self.name) + + return await app_facade.DestroyUnits([self.name]) remove = destroy def get_resources(self, details=False): @@ -42,14 +53,26 @@ class Unit(model.ModelEntity): """ pass - def run(self, command, timeout=None): + async def run(self, command, timeout=None): """Run command on this unit. :param str command: The command to run :param int timeout: Time to wait before command is considered failed """ - pass + action = client.ActionFacade() + action.connect(self.connection) + + log.debug( + 'Running `%s` on %s', command, self.name) + + return await action.Run( + [], + command, + [], + timeout, + [self.name], + ) def run_action(self, action_name, **params): """Run action on this unit.