A script to move all TESS reduce worker tasks from the `internal` queue to the `holding` queue

move_internal.rb

# this assumes the rails console has preloaded the resources; accordingly,
# you should invoke this script as
#
# rails c < move_internal.rb

begin
  args_list = []
  jobs_list = []
  puts 'finding jobs'
  Sidekiq::Queue.new('internal').each do |job|
    if (job.klass=='ReduceWorker') && (job.args[0]==11235)
      args_list.push(job.args)
      jobs_list.push(job)
      if(args_list.size % 20 == 0)
        print '.'
        # .flush
      end
    end

    if (args_list.size == 1000)
      puts "\npushing 1000 jobs"
      Sidekiq::Client.push_bulk('queue' => 'holding', 'class' => ReduceWorker, 'args' => args_list)
      args_list = []
      puts 'deleting jobs'
      ct = 0
      jobs_list.each do |job|
        ct = ct + 1
        print '.' if (ct % 20 == 0)
        job.delete
      end
      jobs_list = []
      puts "\nfinding jobs"
    end
  end
ensure
  puts 'cleaning up'
  puts 'pushing remaining jobs'
  Sidekiq::Client.push_bulk('queue' => 'holding', 'class' => ReduceWorker, 'args' => args_list)
  puts 'deleting jobs'
  ct = 0
  jobs_list.each do |job|
    ct = ct + 1
    print '.' if (ct % 20 == 0)
    job.delete
  end
end