Resque Cheatsheet

DDRevo

To view the id's, classes, and arguments associated with each failed job:

Resque::Failure.each { |id, item| puts "#{id} .. #{item['payload']['args'].first['job_class']} .. #{item['payload']['args'].first['arguments']}" }; puts

Unregister workers:

Resque.workers.select { |w| w.hostname == “e59a53a18489” }.each { |w| w.unregister_worker }

DDR-C

To view the id's, classes, and arguments associated with each failed job:

 Resque::Failure.each { |id, item| puts "#{id} .. #{item['payload']['class']} .. #{item['payload']['args']}" }; puts

To limit to failed jobs of a particular class:

Resque::Failure.each(0, Resque::Failure.count, :failed, 'Ddr::Managers::DerivativesManager::DerivativeJob') { |id, item| puts "#{id} .. #{item['payload']['class']} .. #{item['payload']['args']}" }; puts

Retry and remove failed jobs of a particular class:

Resque::Failure.each(0, Resque::Failure.count, :failed, 'Ddr::Managers::DerivativesManager::DerivativeJob') { |id, item| Resque::Failure.requeue(id); Resque::Failure.remove(id) }

Failed job top-level keys:

Resque::Failure.all.keys
 => ["failed_at", "payload", "exception", "error", "backtrace", "worker", "queue"] 

Failed job "payload" keys:

Resque::Failure.all['payload'].keys
 => ["class", "args"]