Fix for new sidekiq

This commit is contained in:
Kyle Drake 2016-01-23 21:59:23 -08:00
parent aa5d5ccd45
commit 098ec87d39

View file

@ -13,7 +13,7 @@ class ArchiveWorker
return
end
queue = Sidekiq::Queue.new self.class.sidekiq_options_hash['queue']
queue = Sidekiq::Queues[self.class.sidekiq_options_hash['queue']]
logger.info "JOB ID: #{jid} #{site_id.inspect}"
queue.each do |job|
if job.args == [site_id] && job.jid != jid