File tree 2 files changed +9
-0
lines changed
2 files changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -123,6 +123,7 @@ def terminate(reason:)
123
123
with_transaction_returning_status do
124
124
update! stage : :terminated , terminated_at : Time . zone . now , terminate_reason : reason
125
125
126
+ executable &.on_flow_core_task_terminate ( self )
126
127
transition . on_task_terminate ( self )
127
128
instance . on_task_terminate ( self )
128
129
@@ -158,6 +159,7 @@ def suspend
158
159
with_transaction_returning_status do
159
160
update! suspended_at : Time . zone . now
160
161
162
+ executable &.on_flow_core_task_suspend ( self )
161
163
transition . on_task_suspend ( self )
162
164
instance . on_task_suspend ( self )
163
165
@@ -169,6 +171,7 @@ def resume
169
171
with_transaction_returning_status do
170
172
update! suspended_at : nil , resumed_at : Time . zone . now
171
173
174
+ executable &.on_flow_core_task_resume ( self )
172
175
transition . on_task_resume ( self )
173
176
instance . on_task_resume ( self )
174
177
Original file line number Diff line number Diff line change @@ -15,6 +15,12 @@ def finished?
15
15
raise NotImplementedError
16
16
end
17
17
18
+ def on_flow_core_task_terminate ( _task ) ; end
19
+
20
+ def on_flow_core_task_suspend ( _task ) ; end
21
+
22
+ def on_flow_core_task_resume ( _task ) ; end
23
+
18
24
private
19
25
20
26
def implicit_notify_workflow_task_finished
You can’t perform that action at this time.
0 commit comments