saltstack/salt
1
0
Fork 0
mirror of https://github.com/saltstack/salt.git synced 2025-04-17 10:10:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Merge pull request #30699 from abednarik/save_load_retry_time

Browse source 
Add Retry to save_load.
This commit is contained in:
Thomas S Hatch 2016-01-29 09:08:30 -07:00
commit 076268089a
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
salt/returners/local_cache.py
View file

@ -200,10 +200,15 @@ def returner(load):
)
def save_load(jid, clear_load):
def save_load(jid, clear_load, recurse_count=0):
'''
Save the load to the specified jid
'''
if recurse_count >= 5:
err = 'save_load could not write job cache file after {0} retries.'.format(recurse_count)
log.error(err)
raise salt.exceptions.SaltCacheError(err)
jid_dir = _jid_dir(jid)
serial = salt.payload.Serial(__opts__)
@ -235,6 +240,9 @@ def save_load(jid, clear_load):
)
except IOError as exc:
log.warning('Could not write job invocation cache file: {0}'.format(exc))
time.sleep(0.1)
return save_load(jid=jid, clear_load=clear_load,
recurse_count=recurse_count+1)
def get_load(jid):