diff --git a/app/models/solid_queue/blocked_execution.rb b/app/models/solid_queue/blocked_execution.rb index b596b6de..4ad4d239 100644 --- a/app/models/solid_queue/blocked_execution.rb +++ b/app/models/solid_queue/blocked_execution.rb @@ -12,7 +12,7 @@ class BlockedExecution < Execution class << self def unblock(limit) SolidQueue.instrument(:release_many_blocked, limit: limit) do |payload| - expired.distinct.limit(limit).pluck(:concurrency_key).then do |concurrency_keys| + expired.order(:concurrency_key).distinct.limit(limit).pluck(:concurrency_key).then do |concurrency_keys| payload[:size] = release_many releasable(concurrency_keys) end end