File takes a CSV of "okey,root_okey,source_okey" and enqueues work for the "SetRootAndSourceProjectIdsProcessor".

migrant_work_enqueuer.rb

def enqueue_for_migrant_work(okey, root, source)
  queue_name = "migrant_worker_$$$ENVIRONMENTNAME$$$"

  payload = {
    'processor' => 'SetRootAndSourceProjectIdsProcessor',
    'okey'      => okey,
    'root'      => root,
    'source'    => source,
  }

  Resque.push(queue_name, {
    'class' => 'Migrant::Worker',
    'args' => [{
      'timeout' => 500,
      'request_created_at' => Time.now.to_f,
      'payload' => payload
    }]
  })
end

ARGF.each do |line|
  okey, root, source = line.split(",")

  if root.blank?
    root = nil
  end
  if source.blank?
    source = nil
  end

  enqueue_for_migrant_work(okey, root, source)
end