mirror of
https://github.com/valitydev/salt.git
synced 2024-11-08 09:23:56 +00:00
Add __init__ arg to Runner(), and call self.async (since its a subclass)
This commit is contained in:
parent
33d6413e99
commit
6cd18c3641
@ -103,7 +103,7 @@ class Runner(RunnerClient):
|
|||||||
'''
|
'''
|
||||||
Execute the salt runner interface
|
Execute the salt runner interface
|
||||||
'''
|
'''
|
||||||
def __init__(self):
|
def __init__(self, opts):
|
||||||
super(Runner, self).__init__(opts)
|
super(Runner, self).__init__(opts)
|
||||||
self.returners = salt.loader.returners(opts, self.functions)
|
self.returners = salt.loader.returners(opts, self.functions)
|
||||||
self.outputters = salt.loader.outputters(opts)
|
self.outputters = salt.loader.outputters(opts)
|
||||||
@ -136,7 +136,7 @@ class Runner(RunnerClient):
|
|||||||
low['args'] = args
|
low['args'] = args
|
||||||
low['kwargs'] = kwargs
|
low['kwargs'] = kwargs
|
||||||
|
|
||||||
async_pub = super(Runner, self).async(self.opts['fun'], low)
|
async_pub = self.async(self.opts['fun'], low)
|
||||||
# Run the runner!
|
# Run the runner!
|
||||||
if self.opts.get('async', False):
|
if self.opts.get('async', False):
|
||||||
log.info('Running in async mode. Results of this execution may '
|
log.info('Running in async mode. Results of this execution may '
|
||||||
|
Loading…
Reference in New Issue
Block a user