File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
lib/resque/plugins/round_robin Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -34,10 +34,8 @@ def should_work_on_queue? queuename
34
34
# Ive been fighting to get this to round-robining system to work
35
35
# for five hours now. If you hate this, you can fix it.
36
36
#
37
- unless [ 'replays' , 'replays-high' ] . include? ( queuename . to_s ) || queuename . to_s . index ( 'replay' ) . nil?
38
- if Resque . size ( "python" ) > 2
39
- return false
40
- end
37
+ if Resque . size ( "python" ) > 2
38
+ return false
41
39
end
42
40
43
41
return true if @queues . include? '*' # workers with QUEUES=* are special and are not subject to queue depth setting
@@ -60,6 +58,7 @@ def should_round_robin?
60
58
61
59
def reserve_with_round_robin
62
60
if not should_round_robin?
61
+ print "reserving without round robin"
63
62
return reserve_without_round_robin
64
63
end
65
64
You can’t perform that action at this time.
0 commit comments