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.
2 parents df2a37a + 647b90e commit 82e590eCopy full SHA for 82e590e
lib/resque/plugins/round_robin/round_robin.rb
@@ -28,7 +28,9 @@ def queue_depth queuename
28
def should_work_on_queue? queuename
29
return true if @queues.include? '*' # workers with QUEUES=* are special and are not subject to queue depth setting
30
max = DEFAULT_QUEUE_DEPTH
31
- max = ENV["RESQUE_QUEUE_DEPTH"].to_i if ENV["RESQUE_QUEUE_DEPTH"].present?
+ unless ENV["RESQUE_QUEUE_DEPTH"].nil? || ENV["RESQUE_QUEUE_DEPTH"] == ""
32
+ max = ENV["RESQUE_QUEUE_DEPTH"].to_i
33
+ end
34
return true if max == 0 # 0 means no limiting
35
cur_depth = queue_depth(queuename)
36
log! "queue #{queuename} depth = #{cur_depth} max = #{max}"
0 commit comments