ActiveJob с Resque: enqueuing jobs with uninteded arguments

Question

Попытка реализовать какую-то функцию отмены работы. Для того, чтобы destroy a job with Resque, нужны конкретные аргументы, переданные ему. Похоже, я ошибочно передаю непреднамеренную информацию.

Я ожидаю только значение аргументов, чтобы быть в пределах внешних скобок. Я создаю работу так:

PhysicalServerProvisionJob.perform_later('123')       

Я хотел бы быть в состоянии:.

Resque::Job.destroy(:default, PhysicalServerProvisionJob, '123') 

Однако это не представляется возможным из-за дополнительной информации, переданной в случае, если это неизбежно , есть ли другой способ уничтожить конкретную задание в очереди?

Answer 1

С помощью this answer here, я решил проблему таким образом:

Resque.size('default').times do 
    job = Resque.reserve('default') 
    next if job.nil? || job.args.first['arguments'].first == id 
    Resque.push('default', class: job.payload_class.to_s, args: job.args) 
end 

Answer 2

Поскольку Resque::Job.destroy ищет точное соответствие всех аргументов, это не поможет найти класс ActiveJob.

Вот сценарий, я написал для решения этой проблемы:

# Pop jobs off the queue until there are no more 
while job = Resque.reserve('default') 
    # Check this job for the ActiveJob class name we're looking for; 
    # if it does not match, push it back onto a different queue 
    unless job.args.to_s.include?('PhysicalServerProvisionJob') 
    Resque.push('another_queue', class: job.payload_class.to_s, args: job.args) 
    end 
end