diff options
Diffstat (limited to 'morphlib/plugins')
| -rw-r--r-- | morphlib/plugins/distbuild_plugin.py | 20 |
1 files changed, 16 insertions, 4 deletions
diff --git a/morphlib/plugins/distbuild_plugin.py b/morphlib/plugins/distbuild_plugin.py index 2d6d932e..2da089f3 100644 --- a/morphlib/plugins/distbuild_plugin.py +++ b/morphlib/plugins/distbuild_plugin.py @@ -19,6 +19,7 @@ import cliapp import logging import re import sys +import uuid import morphlib import distbuild @@ -70,10 +71,12 @@ class DistbuildCancel(cliapp.Plugin): raise cliapp.AppException( 'usage: morph distbuild-cancel <build-request id>') + args.append('build-cancel') + args.append('Sending cancel request for distbuild job.') addr = self.app.settings['controller-initiator-address'] port = self.app.settings['controller-initiator-port'] icm = distbuild.InitiatorConnectionMachine(self.app, addr, port, - distbuild.InitiatorCancel, + distbuild.InitiatorCommand, [self.app] + args, self.RECONNECT_INTERVAL, self.MAX_RETRIES) @@ -117,10 +120,12 @@ class DistbuildStatusPlugin(cliapp.Plugin): raise cliapp.AppException( 'usage: morph distbuild-status <build-request id>') + args.append('build-status') + args.append('Requesting status of recent build requests.') addr = self.app.settings['controller-initiator-address'] port = self.app.settings['controller-initiator-port'] icm = distbuild.InitiatorConnectionMachine(self.app, addr, port, - distbuild.InitiatorStatus, + distbuild.InitiatorCommand, [self.app] + args, self.RECONNECT_INTERVAL, self.MAX_RETRIES) @@ -159,11 +164,18 @@ class DistbuildListJobsPlugin(cliapp.Plugin): ''' + if len(args) != 0: + raise cliapp.AppException( + 'distbuild-list-jobs takes zero arguments') + + args.append(uuid.uuid4().hex) + args.append('list-requests') + args.append('Requesting currently running distbuilds.') addr = self.app.settings['controller-initiator-address'] port = self.app.settings['controller-initiator-port'] icm = distbuild.InitiatorConnectionMachine(self.app, addr, port, - distbuild.InitiatorListJobs, - [self.app], + distbuild.InitiatorCommand, + [self.app] + args, self.RECONNECT_INTERVAL, self.MAX_RETRIES) loop = distbuild.MainLoop() |