capistrano.rb

require 'resque_utils'

Capistrano::Configuration.instance(:must_exist).load do
  
  namespace :resque do
    
    namespace :failed do
  
      desc "Requeue all failed jobs"
      task :requeue_all do
        set :resque_pre, "cd #{current_path} && RAILS_ENV=#{environment} bundle exec rails runner"
        run "#{resque_pre} 'ResqueUtils::requeue_all'"
      end
  
      desc "Remove all failed jobs"
      task :remove_all do
        set :resque_pre, "cd #{current_path} && RAILS_ENV=#{environment} bundle exec rails runner"
        run "#{resque_pre} 'ResqueUtils::remove_all'"
      end
  
      desc "Requeue specific failed jobs (specify with '--set exception=SomeErrorHere)"
      task :requeue_specific do
        if exists?(:exception)
          set :resque_pre, "cd #{current_path} && RAILS_ENV=#{environment} bundle exec rails runner"
          run "#{resque_pre} \"ResqueUtils::requeue_specific('#{exception}')\""
        else
          raise ArgumentError, "No exception was specified, use '--set exception=SomeErrorHere'"
        end
      end
  
      desc "Remove specific failed jobs (specify with '--set exception=SomeErrorHere)"
      task :remove_specific do
        if exists?(:exception)
          set :resque_pre, "cd #{current_path} && RAILS_ENV=#{environment} bundle exec rails runner"
          run "#{resque_pre} \"ResqueUtils::remove_specific('#{exception}')\""
        else
          raise ArgumentError, "No exception was specified, use '--set exception=SomeErrorHere'"
        end
      end
  
    end
  end
  
end