retry_resque_jobs.rb

namespace :retry do
  require 'rubygems'

  desc 'Retry Resque DirtyExit jobs'
  task resque_dirtyexit_jobs: :environment do
    redis = Resque.redis

    (0...Resque::Failure.count).each do |i|
      serialized_job = redis.lindex(:failed, i)
      job = Resque.decode(serialized_job)

      next if job.nil?
      if job['exception'] == 'Resque::DirtyExit'
        puts "Retry #{job['payload']['class']}"
        Resque::Failure.requeue(i)
        Resque::Failure.remove(i)
      end
    end
  end
  
end