mirror of
https://github.com/valitydev/salt.git
synced 2024-11-07 08:58:59 +00:00
Add some kwargs to the client for syndic
This commit is contained in:
parent
147e712222
commit
fd2c9c8b06
@ -231,7 +231,7 @@ class LocalClient(object):
|
||||
'exsel': self._check_grain_minions,
|
||||
}[expr_form](expr)
|
||||
|
||||
def pub(self, tgt, fun, arg=(), expr_form='glob', ret=''):
|
||||
def pub(self, tgt, fun, arg=(), expr_form='glob', ret='', jid=''):
|
||||
'''
|
||||
Take the required arguments and publish the given command.
|
||||
Arguments:
|
||||
@ -272,6 +272,8 @@ class LocalClient(object):
|
||||
key=self.key,
|
||||
tgt_type=expr_form,
|
||||
ret=ret)
|
||||
if jid:
|
||||
package['jid'] = jid
|
||||
# Prep zmq
|
||||
context = zmq.Context()
|
||||
socket = context.socket(zmq.REQ)
|
||||
@ -280,4 +282,3 @@ class LocalClient(object):
|
||||
payload = salt.payload.unpackage(socket.recv())
|
||||
return {'jid': payload['load']['jid'],
|
||||
'minions': minions}
|
||||
|
||||
|
@ -23,6 +23,7 @@ import salt.utils
|
||||
import salt.modules
|
||||
import salt.returners
|
||||
import salt.loader
|
||||
import salt.client
|
||||
|
||||
log = logging.getLogger(__name__)
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user