Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
3846e8f303
|
|||
07ccb09910
|
|||
235f5b1e07
|
|||
b9c04b8b00
|
@ -79,7 +79,7 @@ def parse_args():
|
||||
|
||||
args = parser.parse_args()
|
||||
if not args.name:
|
||||
args.name = [os.path.basename(args.command[0])]
|
||||
args.name = os.path.basename(args.command[0])
|
||||
|
||||
return args
|
||||
|
||||
@ -166,18 +166,19 @@ def main():
|
||||
args = parse_args()
|
||||
now = datetime.datetime.utcnow()
|
||||
nowstr = now.strftime(time_format)
|
||||
libdir = os.path.join(args.cachedir[0], args.name[0], nowstr)
|
||||
lckdir = os.path.join(args.lockdir[0], args.name[0])
|
||||
libdir = os.path.join(args.cachedir[0], args.name, nowstr)
|
||||
lckdir = os.path.join(args.lockdir[0], args.name)
|
||||
|
||||
|
||||
os.makedirs(lckdir, exist_ok=True)
|
||||
os.makedirs(libdir)
|
||||
lckfile = os.path.join(lckdir, args.name[0])
|
||||
lckfile = os.path.join(lckdir, args.name)
|
||||
outfile = os.path.join(libdir, 'stdout')
|
||||
errfile = os.path.join(libdir, 'stderr')
|
||||
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):
|
||||
res = exec_command(args, o, e, r)
|
||||
else:
|
||||
@ -185,34 +186,38 @@ def main():
|
||||
r.write("\nFalse\n")
|
||||
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 = {}
|
||||
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 = {
|
||||
os.path.join(root, d): datetime.datetime.strptime(d, time_format)
|
||||
for d in dirs
|
||||
if datetime.datetime.strptime(d, time_format) < datetime.datetime.strptime(nowstr, time_format)}
|
||||
break
|
||||
|
||||
if res in args.success_exit_codes:
|
||||
# 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
|
||||
if previous_runs:
|
||||
print("Success after {} failed runs\n".format(len(previous_runs)))
|
||||
print_runs(previous_runs.keys())
|
||||
shutil.rmtree(libdir)
|
||||
return 0
|
||||
if success:
|
||||
# Yes! Success! report any errors until now
|
||||
if previous_runs:
|
||||
print("Success after {} failed runs\n".format(len(previous_runs)))
|
||||
print_runs(previous_runs.keys())
|
||||
shutil.rmtree(libdir)
|
||||
return 0
|
||||
|
||||
|
||||
# Failure
|
||||
if previous_runs:
|
||||
|
Reference in New Issue
Block a user