valitydev/salt
14
0
Fork 0
mirror of https://github.com/valitydev/salt.git synced 2024-11-08 01:18:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix #3579

Browse Source 
salt 'node' state.sls pillar=$(cat /some/yamlorjson/file)
This commit is contained in:
Thomas S Hatch 2013-02-04 13:41:08 -07:00
parent 2073fa2700
commit 436012aeb8
1 changed files with 23 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
salt/modules/state.py
View File

@ -27,6 +27,19 @@ __outputter__ = {
log = logging.getLogger(__name__)
def __resolve_struct(value, kwval_as):
'''
Take a string representing a structure and safely serialize it with the
specified medium
'''
if kwval_as == 'yaml':
return = _yaml_load(value, _YamlCustomLoader)
elif kwval_as == 'json':
return = json.loads(value)
elif kwval_as is None or kwval_as == 'verbatim':
return = value
def running():
'''
Return a dict of state return data if a state function is already running.
@ -132,7 +145,11 @@ def highstate(test=None, **kwargs):
if not test is None:
opts['test'] = test
st_ = salt.state.HighState(opts)
pillar = __resolve_struct(
kwargs.get('pillar', ''),
kwargs.get('kwval_as', 'yaml'))
st_ = salt.state.HighState(opts, pillar)
salt.state.HighState.current = st_
ret = st_.call_highstate(exclude=kwargs.get('exclude', []))
serial = salt.payload.Serial(__opts__)
@ -167,8 +184,12 @@ def sls(mods, env='base', test=None, exclude=None, **kwargs):
if not test is None:
opts['test'] = test
pillar = __resolve_struct(
kwargs.get('pillar', ''),
kwargs.get('kwval_as', 'yaml'))
salt.utils.daemonize_if(opts, **kwargs)
st_ = salt.state.HighState(opts)
st_ = salt.state.HighState(opts, pillar)
if isinstance(mods, string_types):
mods = mods.split(',')