diff --git a/lib/autoload/kuroko2/workflow/engine.rb b/lib/autoload/kuroko2/workflow/engine.rb index 40819358..c8215a66 100644 --- a/lib/autoload/kuroko2/workflow/engine.rb +++ b/lib/autoload/kuroko2/workflow/engine.rb @@ -121,7 +121,7 @@ def process_next(node, token) Notifier.notify(:back_to_normal, token.job_instance) if token.context['RETRYING'] unless token.parent token.job_instance.touch(:finished_at) - Notifier.notify(:finished, token.job_instance) + Notifier.notify(:finished, token.job_instance) unless token.context['RETRYING'] && token.job_definition.notify_back_to_normal? token.destroy! end end