Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
235f5b1e07
|
|||
b9c04b8b00
|
@ -166,18 +166,19 @@ def main():
|
|||||||
args = parse_args()
|
args = parse_args()
|
||||||
now = datetime.datetime.utcnow()
|
now = datetime.datetime.utcnow()
|
||||||
nowstr = now.strftime(time_format)
|
nowstr = now.strftime(time_format)
|
||||||
libdir = os.path.join(args.cachedir[0], args.name[0], nowstr)
|
libdir = os.path.join(args.cachedir[0], args.name, nowstr)
|
||||||
lckdir = os.path.join(args.lockdir[0], args.name[0])
|
lckdir = os.path.join(args.lockdir[0], args.name)
|
||||||
|
|
||||||
|
|
||||||
os.makedirs(lckdir, exist_ok=True)
|
os.makedirs(lckdir, exist_ok=True)
|
||||||
os.makedirs(libdir)
|
os.makedirs(libdir)
|
||||||
lckfile = os.path.join(lckdir, args.name[0])
|
lckfile = os.path.join(lckdir, args.name)
|
||||||
outfile = os.path.join(libdir, 'stdout')
|
outfile = os.path.join(libdir, 'stdout')
|
||||||
errfile = os.path.join(libdir, 'stderr')
|
errfile = os.path.join(libdir, 'stderr')
|
||||||
resfile = os.path.join(libdir, 'result')
|
resfile = os.path.join(libdir, 'result')
|
||||||
|
|
||||||
with open(outfile, 'w') as o, open(errfile, 'w') as e, open(resfile, 'w') as r:
|
success = True
|
||||||
|
with open(outfile, 'w') as o, open(errfile, 'w+') as e, open(resfile, 'w') as r:
|
||||||
if args.no_lock or aquire_lock(lckfile):
|
if args.no_lock or aquire_lock(lckfile):
|
||||||
res = exec_command(args, o, e, r)
|
res = exec_command(args, o, e, r)
|
||||||
else:
|
else:
|
||||||
@ -185,28 +186,31 @@ def main():
|
|||||||
r.write("\nFalse\n")
|
r.write("\nFalse\n")
|
||||||
res = False
|
res = False
|
||||||
|
|
||||||
|
if res in args.success_exit_codes:
|
||||||
|
# Possible success, check error output
|
||||||
|
re_checks = [re.compile(r) for r in args.ignore_error]
|
||||||
|
e.seek(0)
|
||||||
|
for line in e:
|
||||||
|
success = False
|
||||||
|
for r in re_checks:
|
||||||
|
if re.match(r, line):
|
||||||
|
success = True
|
||||||
|
break
|
||||||
|
if not success:
|
||||||
|
break
|
||||||
|
else:
|
||||||
|
success = False
|
||||||
|
|
||||||
|
|
||||||
previous_runs = {}
|
previous_runs = {}
|
||||||
for root, dirs, files in os.walk(os.path.join(args.cachedir[0], args.name[0])):
|
for root, dirs, files in os.walk(os.path.join(args.cachedir[0], args.name)):
|
||||||
previous_runs = {
|
previous_runs = {
|
||||||
os.path.join(root, d): datetime.datetime.strptime(d, time_format)
|
os.path.join(root, d): datetime.datetime.strptime(d, time_format)
|
||||||
for d in dirs
|
for d in dirs
|
||||||
if datetime.datetime.strptime(d, time_format) < datetime.datetime.strptime(nowstr, time_format)}
|
if datetime.datetime.strptime(d, time_format) < datetime.datetime.strptime(nowstr, time_format)}
|
||||||
break
|
break
|
||||||
|
|
||||||
if res in args.success_exit_codes:
|
if success:
|
||||||
# Possible success, check error output
|
|
||||||
re_checks = [re.compile(r) for r in args.ignore_error]
|
|
||||||
ok = True
|
|
||||||
with open(errfile, 'r') as f:
|
|
||||||
for line in f:
|
|
||||||
ok = False
|
|
||||||
for r in re_checks:
|
|
||||||
if re.match(r, line):
|
|
||||||
ok = True
|
|
||||||
break
|
|
||||||
if not ok:
|
|
||||||
break
|
|
||||||
if ok:
|
|
||||||
# Yes! Success! report any errors until now
|
# Yes! Success! report any errors until now
|
||||||
if previous_runs:
|
if previous_runs:
|
||||||
print("Success after {} failed runs\n".format(len(previous_runs)))
|
print("Success after {} failed runs\n".format(len(previous_runs)))
|
||||||
@ -214,6 +218,7 @@ def main():
|
|||||||
shutil.rmtree(libdir)
|
shutil.rmtree(libdir)
|
||||||
return 0
|
return 0
|
||||||
|
|
||||||
|
|
||||||
# Failure
|
# Failure
|
||||||
if previous_runs:
|
if previous_runs:
|
||||||
# Not the first failure...
|
# Not the first failure...
|
||||||
|
2
setup.py
2
setup.py
@ -5,7 +5,7 @@ with open('README.md', 'r') as fh:
|
|||||||
|
|
||||||
setuptools.setup(
|
setuptools.setup(
|
||||||
name='cronwrapper',
|
name='cronwrapper',
|
||||||
version='0.1.0',
|
version='0.1.1',
|
||||||
author='Fredrik Eriksson',
|
author='Fredrik Eriksson',
|
||||||
author_email='feffe@fulh.ax',
|
author_email='feffe@fulh.ax',
|
||||||
description='A small wrapper to handle cronjob failures',
|
description='A small wrapper to handle cronjob failures',
|
||||||
|
Reference in New Issue
Block a user