gistfile1.txt

namespace :delayed_job do
  task :kill_stale_processes => :environment do
    pid_list = IO::popen('ps aux|awk "{if (\$11 ~ \"delayed_job\") print \$2}"')
    pids = pid_list.read.split(/\W+/)
    pids.each do |pid|
      %x[kill -9 #{pid}]
    end
    puts "Killed unresponsive delayed_job pids: #{pids.join(', ')}" if pids.any?
  end
end