class Resque::Plugins::Stages::Cleaner

A class for cleaning up stranded objects for the Stages plugin

Public Class Methods

cleanup_jobs() click to toggle source
# File lib/resque/plugins/stages/cleaner.rb, line 23
def cleanup_jobs
  jobs = redis.keys("StagedJob::*")

  jobs.each do |job_key|
    job = Resque::Plugins::Stages::StagedJob.new(job_key[11..])

    job.verify
  end
end
purge_all() click to toggle source
# File lib/resque/plugins/stages/cleaner.rb, line 15
def purge_all
  keys = redis.keys("*")

  return if keys.blank?

  redis.del(*keys)
end
redis() click to toggle source
# File lib/resque/plugins/stages/cleaner.rb, line 11
def redis
  @redis ||= Resque::Plugins::Stages::Cleaner.new.redis
end