dsaveliev · September 23, 2013 10:43 · Sep 20, 2011 · Sep 20, 2011 · Sep 20, 2011
diff --git a/resque.rake b/resque.rake
@@ -7,10 +7,17 @@ namespace :resque do
   task :clear => :environment do
     queues = Resque.queues
     queues.each do |queue_name|
-      puts "Cleaning #{queue_name}..."
+      puts "Clearing #{queue_name}..."
       Resque.redis.del "queue:#{queue_name}"
     end
-    puts "Cleaning stats..."
+
+    puts "Clearing delayed..." # in case of scheduler - doesn't break if no scheduler module is installed
+    Resque.redis.keys("delayed:*").each do |key|
+      Resque.redis.del "#{key}"
+    end
+    Resque.redis.del "delayed_queue_schedule"
+
+    puts "Clearing stats..."
     Resque.redis.set "stat:failed", 0 
     Resque.redis.set "stat:processed", 0
   end

diff --git a/resque.rake b/resque.rake
@@ -5,7 +5,7 @@
 namespace :resque do
   desc "Clear pending tasks"
   task :clear => :environment do
-    queues = [:followups, :experts, :feedbacks, :invitations, :payouts, :questions, :notifications] # list your queues here
+    queues = Resque.queues
     queues.each do |queue_name|
       puts "Cleaning #{queue_name}..."
       Resque.redis.del "queue:#{queue_name}"

diff --git a/resque.rake b/resque.rake
@@ -0,0 +1,17 @@
+# see http://stackoverflow.com/questions/5880962/how-to-destroy-jobs-enqueued-by-resque-workers - old version
+# see https://github.com/defunkt/resque/issues/49
+# see http://redis.io/commands - new commands
+
+namespace :resque do
+  desc "Clear pending tasks"
+  task :clear => :environment do
+    queues = [:followups, :experts, :feedbacks, :invitations, :payouts, :questions, :notifications] # list your queues here
+    queues.each do |queue_name|
+      puts "Cleaning #{queue_name}..."
+      Resque.redis.del "queue:#{queue_name}"
+    end
+    puts "Cleaning stats..."
+    Resque.redis.set "stat:failed", 0 
+    Resque.redis.set "stat:processed", 0
+  end
+end