X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=juju%2Funit.py;h=9a7540459cfc320eac17eaa0de1c4e358223ccfe;hb=de5d31a2f09275264d3139720f5a287cef8b438b;hp=cad4bb7ac9cf6f0398affc71f32d294ffe0c5c9f;hpb=5ff1c23a9ce16a3179537d75a80f9e80869f0431;p=osm%2FN2VC.git diff --git a/juju/unit.py b/juju/unit.py index cad4bb7..9a75404 100644 --- a/juju/unit.py +++ b/juju/unit.py @@ -1,5 +1,6 @@ import logging -from datetime import datetime + +from dateutil.parser import parse as parse_date from . import model from .client import client @@ -13,48 +14,42 @@ class Unit(model.ModelEntity): """Returns the current agent status string. """ - return self.data['agent-status']['current'] + return self.safe_data['agent-status']['current'] @property def agent_status_since(self): """Get the time when the `agent_status` was last updated. """ - since = self.data['agent-status']['since'] - # Juju gives us nanoseconds, but Python only supports microseconds - since = since[:26] - return datetime.strptime(since, "%Y-%m-%dT%H:%M:%S.%f") + return parse_date(self.safe_data['agent-status']['since']) @property def agent_status_message(self): """Get the agent status message. """ - return self.data['agent-status']['message'] + return self.safe_data['agent-status']['message'] @property def workload_status(self): """Returns the current workload status string. """ - return self.data['workload-status']['current'] + return self.safe_data['workload-status']['current'] @property def workload_status_since(self): """Get the time when the `workload_status` was last updated. """ - since = self.data['workload-status']['since'] - # Juju gives us nanoseconds, but Python only supports microseconds - since = since[:26] - return datetime.strptime(since, "%Y-%m-%dT%H:%M:%S.%f") + return parse_date(self.safe_data['workload-status']['since']) @property def workload_status_message(self): """Get the workload status message. """ - return self.data['workload-status']['message'] + return self.safe_data['workload-status']['message'] @property def tag(self): @@ -111,9 +106,7 @@ 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. + :returns: A :class:`juju.action.Action` instance. """ action = client.ActionFacade() @@ -136,11 +129,12 @@ class Unit(model.ModelEntity): :param str action_name: Name of action to run :param \*\*params: Action parameters - :returns: An `juju.action.Action` instance. + :returns: A :class:`juju.action.Action` instance. Note that this only enqueues the action. You will need to call ``action.wait()`` on the resulting `Action` instance if you wish to block until the action is complete. + """ action_facade = client.ActionFacade() action_facade.connect(self.connection) @@ -242,8 +236,8 @@ class Unit(model.ModelEntity): if not status.applications[app]['units'].get(self.name): return False - return status.applications[app]['units'][self.name].get('leader', False) - + return status.applications[app]['units'][self.name].get('leader', + False) async def get_metrics(self): metrics = await self.model.get_metrics(self.tag)