lib/acidic_job/step.rb in acidic_job-1.0.0.pre22 vs lib/acidic_job/step.rb in acidic_job-1.0.0.pre23
- old
+ new
@@ -40,10 +40,16 @@
end
# The progression phase advances the job run state machine onto the next step
def progress
@run.with_lock do
- @step_result.call(run: @run)
+ if @step_result.is_a?(FinishedPoint)
+ @job.run_callbacks :finish do
+ @step_result.call(run: @run)
+ end
+ else
+ @step_result.call(run: @run)
+ end
end
end
private