feffe/cronwrapper
1
0
Fork 0
Code Issues Pull Requests Projects Releases 6 Wiki Activity

ignore cronjobs that hasn't written any status file yet

Browse Source
This commit is contained in:
Fredrik Eriksson 2020-12-17 16:45:47 +01:00
parent 572f43010e
commit a69cde3160
Signed by: feffe
GPG Key ID: F4329687B0FA7F8D
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
cronwrapper/__init__.py
View File

@ -207,10 +207,16 @@ def main():
previous_runs = {} previous_runs = {}
for root, dirs, files in os.walk(os.path.join(args.cachedir[0], args.name)): for root, dirs, files in os.walk(os.path.join(args.cachedir[0], args.name)):
previous_runs = { for d in dirs:
os.path.join(root, d): datetime.datetime.strptime(d, time_format) if datetime.datetime.strptime(d, time_format) < datetime.datetime.strptime(nowstr, time_format):
for d in dirs with open(os.path.join(root, d, 'result'), 'r') as f:
if datetime.datetime.strptime(d, time_format) < datetime.datetime.strptime(nowstr, time_format)} try:
retcode = f.read().splitlines()[-1]
except IndexError:
# Previous run is probably not completed yet, ignore
# this entry
continue
previous_runs[os.path.join(root, d)] = datetime.datetime.strptime(d, time_format)
break break
if success: if success: