We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 23799d2 commit 766d636Copy full SHA for 766d636
lib/resque/plugins/round_robin/round_robin.rb
@@ -34,7 +34,7 @@ def should_work_on_queue? queuename
34
# Ive been fighting to get this to round-robining system to work
35
# for five hours now. If you hate this, you can fix it.
36
#
37
- if queuename != 'replay' && !queuename.to_s.index('replay').nil?
+ if queuename.to_s != 'replay' && !queuename.to_s.index('replay').nil?
38
if Resque.size("python") > 2
39
return false
40
end
@@ -56,11 +56,6 @@ def reserve_with_round_robin
56
57
qs = rotated_queues
58
qs.each do |queue|
59
-
60
- if queue.to_s.index("replay")
61
62
- end
63
64
log! "Checking #{queue}"
65
if should_work_on_queue?(queue) && job = Resque::Job.reserve(queue)
66
log! "Found job on #{queue}"
0 commit comments