redis-namespace is needed

This commit is contained in:
Kyle Drake 2016-01-24 15:41:11 -08:00
parent 939d902b71
commit b51bb9d917
3 changed files with 6 additions and 1 deletions

View file

@ -1,4 +1,5 @@
require 'sidekiq/api'
require 'redis-namespace'
class ArchiveWorker
include Sidekiq::Worker
@ -13,7 +14,7 @@ class ArchiveWorker
return
end
queue = Sidekiq::Queues[self.class.sidekiq_options_hash['queue']]
queue = Sidekiq::Queue.new 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