Implement Application.run()
authorTim Van Steenburgh <tvansteenburgh@gmail.com>
Tue, 1 Nov 2016 22:39:40 +0000 (18:39 -0400)
committerTim Van Steenburgh <tvansteenburgh@gmail.com>
Tue, 1 Nov 2016 22:39:40 +0000 (18:39 -0400)
juju/application.py
juju/unit.py

index 272268d..4a98622 100644 (file)
@@ -213,14 +213,27 @@ class Application(model.ModelEntity):
         """
         pass
 
-    def run(self, command, timeout=None):
+    async def run(self, command, timeout=None):
         """Run command on all units for this application.
 
         :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 all units of %s', command, self.name)
+
+        # TODO this should return a list of Actions
+        return await action.Run(
+            [self.name],
+            command,
+            [],
+            timeout,
+            [],
+        )
 
     async def set_annotations(self, annotations):
         """Set annotations on this application.
index 4b24331..d0bbd32 100644 (file)
@@ -115,6 +115,7 @@ class Unit(model.ModelEntity):
         log.debug(
             'Running `%s` on %s', command, self.name)
 
+        # TODO this should return an Action
         return await action.Run(
             [],
             command,