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