From cbb7650e359f8870cd59501bc0e9904d5a9e6ea6 Mon Sep 17 00:00:00 2001 From: "Krzysztof A. Adamski" Date: Sat, 31 May 2008 07:44:07 -0400 Subject: Added --jobthing option to 'call' cmd_module. --- func/overlord/cmd_modules/call.py | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) (limited to 'func') diff --git a/func/overlord/cmd_modules/call.py b/func/overlord/cmd_modules/call.py index bc21b51..fcae0b3 100644 --- a/func/overlord/cmd_modules/call.py +++ b/func/overlord/cmd_modules/call.py @@ -52,9 +52,12 @@ class Call(base_command.BaseCommand): self.parser.add_option("-n", "--nopoll", dest="nopoll", help="Don't wait for async results", action="store_true") - self.parser.add_option("-s", "--sort", dest="sort", + self.parser.add_option("", "--sort", dest="sort", help="In async mode, wait for all results and print them sorted.", action="store_true") + self.parser.add_option("-s", "--jobstatus", dest="jobstatus", + help="Do not run any job, just check for status.", + action="store_true") def handleOptions(self, options): self.options = options @@ -124,12 +127,19 @@ class Call(base_command.BaseCommand): self.getOverlord() - results = self.overlord_obj.run(self.module, self.method, self.method_args) + if not self.options.jobstatus: + results = self.overlord_obj.run(self.module, self.method, self.method_args) + else: + (return_code, async_results) = self.overlord_obj.job_status(float(self.module)) + res = self.format_return((return_code, async_results)) + print res + return 0 if self.options.async: partial = {} if self.options.nopoll: - print "JOB_ID", results + print "JOB_ID:", pprint.pformat(results) + return 0 else: async_done = False while not async_done: -- cgit