X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=juju%2Funit.py;h=3dbc1e963577c8882ada5457aa0396073ca21493;hb=edc3fa5061258968907f7cb9454fd43576f956bd;hp=4b24331a54fad487e58eb4d0136b81a774894a28;hpb=3a10e9365e5946c806219b870a464983ab4d879c;p=osm%2FN2VC.git diff --git a/juju/unit.py b/juju/unit.py index 4b24331..3dbc1e9 100644 --- a/juju/unit.py +++ b/juju/unit.py @@ -1,3 +1,4 @@ +import asyncio import logging from datetime import datetime @@ -108,6 +109,9 @@ class Unit(model.ModelEntity): :param str command: The command to run :param int timeout: Time to wait before command is considered failed + Returns a tuple containing the stdout, stderr, and return code + from the command. + """ action = client.ActionFacade() action.connect(self.connection) @@ -115,13 +119,14 @@ class Unit(model.ModelEntity): log.debug( 'Running `%s` on %s', command, self.name) - return await action.Run( + res = await action.Run( [], command, [], timeout, [self.name], ) + return await self.model.wait_for_action(res.results[0].action.tag) def run_action(self, action_name, **params): """Run action on this unit.