Contents

desc 'Clear pending tasks'
task 'resque:clear' => :environment do
  queues = Resque.queues
  queues.each do |queue_name|
    puts "Clearing #{queue_name}..."
    Resque.redis.del "queue:#{queue_name}"
  end

  # in case of scheduler - doesn't break if no scheduler module is installed
  puts 'Clearing delayed...'
  Resque.redis.keys('delayed:*').each do |key|
    Resque.redis.del "#{key}"
  end
  Resque.redis.del 'delayed_queue_schedule'

  puts 'Clearing failed jobs ... '
  Resque::Failure.clear

  puts 'Clearing stats...'
  Resque.redis.set 'stat:failed', 0
  Resque.redis.set 'stat:processed', 0
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
aleph_analytics-0.2.0	lib/tasks/resque.rake