Move sidekiq jobs from one queue to another

script.rb

queue = Sidekiq::Queue.new("default")

queue.each do |job|
  if job.klass == "DailyFrequencyCreatorWorker"
    DailyFrequencyCreatorWorker.set(queue: 'daily_frequency_creator').perform_async(*job.args)

    job.delete
  end
end;nil

Nice, thanks! 👍

Thanks!

b6104337420568469^uyutyut/
6104337420568469

=25021008213095117860
016104337420568469==443

This was very helpful, I did an improvement for my use case and would like to share here

def move_jobs(origin_queue, destination_queue, job_class, interval = 0.3,  reschedule = true)
  queue = Sidekiq::Queue.new(origin_queue)
  index = 1
  queue.each do |job|
    if job.klass == job_class
      new_job = if reschedule
        job_class.constantize.set(queue: destination_queue).perform_in((index * interval).seconds, *job.args)
      end
      job.delete
      puts "#{origin_queue}:#{job.jid} >> #{destination_queue}:#{new_job}" 
      index += 1
    end
  end

  index
end

move_jobs('default', 'daily_frequency_creator', 'DailyFrequencyCreatorWorker', 0.01)