diff --git a/app/models/solid_queue/ready_execution.rb b/app/models/solid_queue/ready_execution.rb index 8eeaddc8..90699ef1 100644 --- a/app/models/solid_queue/ready_execution.rb +++ b/app/models/solid_queue/ready_execution.rb @@ -37,7 +37,7 @@ def lock_candidates(job_ids, process_id) return [] if job_ids.none? SolidQueue::ClaimedExecution.claiming(job_ids, process_id) do |claimed| - where(job_id: claimed.pluck(:job_id)).delete_all + where(id: where(job_id: claimed.pluck(:job_id)).pluck(:id)).delete_all end end