Skip to content
This repository was archived by the owner on Jun 5, 2023. It is now read-only.

Commit 89811a7

Browse files
committed
Merge pull request #140 from sontek/always_run_after_perform
Always run after_perform, you should check 'failed' key
2 parents 49aebb2 + 943a4a2 commit 89811a7

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

pyres/job.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,6 @@ def perform(self):
8282
payload_class.before_perform(metadata)
8383
return payload_class.perform(*args)
8484
except Exception as e:
85-
check_after = False
8685
metadata["failed"] = True
8786
metadata["exception"] = e
8887
if not self.retry(payload_class, args):
@@ -93,8 +92,10 @@ def perform(self):
9392
logging.exception("Retry scheduled after error in %s", self._payload)
9493
finally:
9594
after_perform = getattr(payload_class, "after_perform", None)
96-
if after_perform and check_after:
95+
96+
if after_perform:
9797
payload_class.after_perform(metadata)
98+
9899
delattr(payload_class,'resq')
99100

100101
def fail(self, exception):

0 commit comments

Comments
 (0)