Merge pull request #140 from sontek/always_run_after_perform

Always run after_perform, you should check 'failed' key
binarymatt · Sep 1, 2014 · 89811a7 · 89811a7
2 parents 49aebb2 + 943a4a2
commit 89811a7
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pyres/job.py b/pyres/job.py
@@ -82,7 +82,6 @@ def perform(self):
                 payload_class.before_perform(metadata)
             return payload_class.perform(*args)
         except Exception as e:
-            check_after = False
             metadata["failed"] = True
             metadata["exception"] = e
             if not self.retry(payload_class, args):
@@ -93,8 +92,10 @@ def perform(self):
                 logging.exception("Retry scheduled after error in %s", self._payload)
         finally:
             after_perform = getattr(payload_class, "after_perform", None)
-            if after_perform and check_after:
+
+            if after_perform:
                 payload_class.after_perform(metadata)
+
             delattr(payload_class,'resq')
 
     def fail(self, exception):