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

backporting #22226 to 2014.7

Browse Source
This commit is contained in:
Gareth J. Greenaway 2015-03-31 17:31:07 -07:00
parent 8b726e3310
commit 20199351e6
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
salt/utils/schedule.py
View File

@ -379,6 +379,11 @@ class Schedule(object):
jobcount = 0
for basefilename in os.listdir(salt.minion.get_proc_dir(self.opts['cachedir'])):
fn_ = os.path.join(salt.minion.get_proc_dir(self.opts['cachedir']), basefilename)
if not os.path.exists(fn_):
log.debug('schedule.handle_func: {0} was processed '
'in another thread, skipping.'.format(
basefilename))
continue
with salt.utils.fopen(fn_, 'r') as fp_:
job = salt.payload.Serial(self.opts).load(fp_)
if job: