lib/rocket_job/plugins/job/state_machine.rb in rocketjob-3.0.0.beta3 vs lib/rocket_job/plugins/job/state_machine.rb in rocketjob-3.0.0.rc1
- old
+ new
@@ -75,10 +75,10 @@
transitions from: :paused, to: :aborted
end
event :requeue do
transitions from: :running, to: :queued,
- if: -> _worker_name { worker_name == _worker_name },
+ if: -> server_name { worker_name.start_with?(server_name) },
after: :rocket_job_clear_started_at
end
end
# @formatter:on