File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -73,14 +73,16 @@ def perform(self):
73
73
metadata ["enqueue_timestamp" ] = self .enqueue_timestamp
74
74
75
75
before_perform = getattr (payload_class , "before_perform" , None )
76
- if before_perform :
77
- before_perform (metadata )
78
76
79
77
metadata ["failed" ] = False
80
78
metadata ["perform_timestamp" ] = time .time ()
79
+ check_after = True
81
80
try :
81
+ if before_perform :
82
+ before_perform (metadata )
82
83
return payload_class .perform (* args )
83
84
except :
85
+ check_after = False
84
86
metadata ["failed" ] = True
85
87
if not self .retry (payload_class , args ):
86
88
metadata ["retried" ] = False
@@ -89,7 +91,7 @@ def perform(self):
89
91
metadata ["retried" ] = True
90
92
finally :
91
93
after_perform = getattr (payload_class , "after_perform" , None )
92
- if after_perform :
94
+ if after_perform and check_after :
93
95
after_perform (metadata )
94
96
95
97
def fail (self , exception ):
You can’t perform that action at this time.
0 commit comments