diff --git a/app/models/solid_queue/ready_execution.rb b/app/models/solid_queue/ready_execution.rb index 35a11292..ea14c193 100644 --- a/app/models/solid_queue/ready_execution.rb +++ b/app/models/solid_queue/ready_execution.rb @@ -30,7 +30,8 @@ def select_and_lock(queue_relation, process_id, limit) end def select_candidates(queue_relation, limit) - queue_relation.ordered.limit(limit).non_blocking_lock.select(:id, :job_id) + # Force query execution here with #to_a to avoid unintended FOR UPDATE query executions + queue_relation.ordered.limit(limit).non_blocking_lock.select(:id, :job_id).to_a end def lock_candidates(executions, process_id)