lib/good_job/execution.rb in good_job-2.4.1 vs lib/good_job/execution.rb in good_job-2.4.2
- old
+ new
@@ -172,16 +172,10 @@
unfinished.priority_ordered.only_scheduled.limit(1).with_advisory_lock(unlock_session: true) do |executions|
execution = executions.first
break if execution.blank?
break :unlocked unless execution&.executable?
- begin
- execution.with_advisory_lock(key: "good_jobs-#{execution.active_job_id}") do
- execution.perform
- end
- rescue RecordAlreadyAdvisoryLockedError => e
- ExecutionResult.new(value: nil, handled_error: e)
- end
+ execution.perform
end
end
# Fetches the scheduled execution time of the next eligible Execution(s).
# @param after [DateTime]