Установка приоритета с ActiveJob при использовании Delayed :: Job

Question

Как установить приоритет отложенного задания при использовании ActiveJob для постановки в очередь ваших заданий?

class GuestsCleanupJob < ApplicationJob
  queue_as :high_priority

  def perform(*guests)
    # Do something later
  end
end

Answer 1

Решение, использующее Delayed :: Worker.queue_attributes, выглядит нормально и задокументировано, но у меня не сработало ... Все задания имели приоритет = 0 независимо от приоритета очереди, установленного в queue_attributes.Это сработало для меня:

class GuestsCleanupJob < ApplicationJob
  queue_as :high_priority

  def priority
    1
  end

  def perform(*guests)
    # Do something later
  end
end

Answer 2

Это заняло у меня некоторое время, но я нашел этот метод в документации Delayed :: Job:

Delayed::Worker.queue_attributes = {
  default:       { priority: 11 },
  high_priority: { priority: 1 },
  low_priority:  { priority: 75 }
}

Я добавил это в свои инициализаторы и просто хотел поделиться, если кто-то еще столкнется с этим!