Commit 45c40524 by Michael DeHaan

Time limit needs to be passed to async_wrapper.

parent a06d8859
......@@ -221,7 +221,7 @@ class Runner(object):
async = self._transfer_module(conn, tmp, 'async_wrapper')
module = self._transfer_module(conn, tmp, self.module_name)
new_args = []
new_args = [ self.generated_jid, module ]
new_args = [ self.generated_jid, module, self.background ]
new_args.extend(self.module_args)
result = self._execute_module(conn, tmp, async, new_args)
return self._return_from_module(conn, host, result)
......
......@@ -32,13 +32,14 @@ import traceback
if len(sys.argv) < 3:
print json.dumps({
"failed" : True,
"msg" : "usage: async_wrapper <jid> <module_script> <args>. Humans, do not call directly!"
"msg" : "usage: async_wrapper <jid> <module_script> <time_limit> <args>. Humans, do not call directly!"
})
sys.exit(1)
jid = sys.argv[1]
wrapped_module = sys.argv[2]
args = sys.argv[3:]
time_limit = sys.argv[3]
args = sys.argv[4:]
cmd = "%s %s" % (wrapped_module, " ".join(args))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment