ugly, brutish DJ throughput task

dj_throughput.rb

task :dj_throughput, roles: :delayed_job do
  last_reported = Time.now
  completed = {}
  run "tail -f #{shared_path}/log/delayed_job.log" do |channel, stream, data|
    host = channel[:host]
    trap("INT") { puts 'Interupted'; exit 0; }
    if data =~ /completed after/
      completed[host] ||= 0
      completed[host] += 1
    end

    now = Time.now
    if now - last_reported > 5
      elapsed =  now - last_reported
      last_reported = now

      total = 0

      # this string clears the screen so I don't have to use curses.  google it!
      puts "\e[H\e[2J"
      completed.each do |host, num_completed|
        total += num_completed
        puts "#{host}: #{num_completed} in #{elapsed}, #{num_completed/elapsed} jobs/s"
      end
      completed = {}

      puts "total: #{total} in #{elapsed}, #{total/elapsed} jobs/s" 

    end
    
    break if stream == :err
  end
end