bump version

--no-lock is used

cronwrapper/__init__.py

@@ -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
 
@@ -159,25 +159,29 @@ def print_runs(runs, clean=True):
         print("\n\n")
     if clean:
         for run in runs:
+            try:
                 shutil.rmtree(run)
+            except FileNotFoundError:
+                pass
 
 def main():
     time_format = '%Y-%m-%d_%H%M'
     args = parse_args()
     now = datetime.datetime.utcnow()
     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(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,35 +189,48 @@ def main():
             r.write("\nFalse\n")
             res = False
 
-    previous_runs = {}
-    for root, dirs, files in os.walk(os.path.join(args.cachedir[0], args.name[0])):
-        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
+            e.seek(0)
-        with open(errfile, 'r') as f:
+            for line in e:
-            for line in f:
+                success = False
-                ok = False
                 for r in re_checks:
                     if re.match(r, line):
-                        ok = True
+                        success = True
                         break
-                if not ok:
+                if not success:
                     break
-        if ok:
+        else:
+            success = False
+
+
+    previous_runs = {}
+    for root, dirs, files in os.walk(os.path.join(args.cachedir[0], args.name)):
+        for d in dirs:
+            if datetime.datetime.strptime(d, time_format) < datetime.datetime.strptime(nowstr, time_format):
+                with open(os.path.join(root, d, 'result'), 'r') as f:
+                    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
+
+    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())
+        try:
             shutil.rmtree(libdir)
+        except FileNotFoundError:
+            pass
         return 0 
 
+
     # Failure
     if previous_runs:
         # Not the first failure...

setup.py

@@ -5,7 +5,7 @@ with open('README.md', 'r') as fh:
 
 setuptools.setup(
         name='cronwrapper',
-        version='0.1.0',
+        version='0.1.4',
         author='Fredrik Eriksson',
         author_email='feffe@fulh.ax',
         description='A small wrapper to handle cronjob failures',