We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ad8c332 commit 05b579bCopy full SHA for 05b579b
lib/resque/failure.rb
@@ -67,6 +67,8 @@ def self.remove(index)
67
backend.remove(index)
68
end
69
70
+ # Requeues all failed jobs in a specific queue.
71
+ # Queue name should be a string.
72
def self.requeue_queue(queue)
73
i=0
74
while job = Resque::Failure.all(i)
@@ -77,11 +79,13 @@ def self.requeue_queue(queue)
77
79
78
80
81
82
+ # Removes all failed jobs in a specific queue.
83
84
def self.remove_queue(queue)
85
86
87
if job['queue'] == queue
- # This will remove from the queue so don't increment the index
88
+ # This will remove the failure from the array so do not increment the index.
89
Resque::Failure.remove(i)
90
else
91
i+=1
0 commit comments