Class for case when queue for worker was changed but there are a lot of scheduled jobs in queue previously used

jobs_mover.rb

class JobsMover
  BATCH_SIZE = 100

  def initialize(original_queue, klass)
    @original_queue = Sidekiq::Queue.new(original_queue)
    @klass = klass
  end

  def move
    jobs = @original_queue.select { |job| job.item['class'] == @klass }
    total = jobs.count
    progress = 0

    jobs.each_slice(BATCH_SIZE) do |jobs_set|
      jobs_set.each do |job|
        job.delete
        @klass.constantize.perform_async(*job.item['args'])
      end
      print "#{progress += BATCH_SIZE} / #{total} \r"
    end
  end
end

jobs_remover.rb

class JobsRemover
  BATCH_SIZE = 100

  def initialize(original_queue, klass)
    @original_queue = Sidekiq::Queue.new(original_queue)
    @klass = klass
  end

  def remove
    jobs = @original_queue.select { |job| job.item['class'] == @klass }
    total = jobs.count
    progress = 0

    jobs.each_slice(BATCH_SIZE) do |jobs_set|
      jobs_set.each do |job|
        job.delete
      end
      print "#{progress += BATCH_SIZE} / #{total} \r"
    end
  end
end

https://github.com/mperham/sidekiq/wiki/FAQ#how-do-i-cancel-a-sidekiq-job