Sidekiq / Redis / Queues

sidekiq_queues_redis.md

Check your queues

name_count = { }
queues = Sidekiq::Queue.all
queues.each do |queue|
  names = queue.map { |q| q.klass == 'ActiveJob::QueueAdapters::SidekiqAdapter::JobWrapper' ? q['wrapped'] : q.klass }
  foo = names.each do |n| 
    name_count[n] ||= 0
    name_count[n] += 1 
  end
end
name_count.sort

Retries

jobs = []
retries = Sidekiq::RetrySet.new
retries.each do |item|
  queue = item.queue
  name = item.klass
  args = item.args
  jid = item.jid
  jobs << { queue: queue, name: name, args: args, jid: jid }
end

puts Sidekiq::Queue.new(queue).group_by(&:display_class).map { |klass, jobs| [klass, jobs.size] }.to_json