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 57bb576 commit 4d530b8Copy full SHA for 4d530b8
lib/resque/worker.rb
@@ -35,17 +35,17 @@ def self.working
35
36
names.map! { |name| "worker:#{name}" }
37
38
- reportedly_working = begin
39
- redis.mapped_mget(*names).reject do |key, value|
+ reportedly_working = {}
+
40
+ begin
41
+ reportedly_working = redis.mapped_mget(*names).reject do |key, value|
42
value.nil? || value.empty?
43
end
44
rescue Redis::Distributed::CannotDistribute
- result = {}
45
names.each do |name|
46
value = redis.get name
- result[name] = value unless value.nil? || value.empty?
47
+ reportedly_working[name] = value unless value.nil? || value.empty?
48
- result
49
50
51
reportedly_working.keys.map do |key|
0 commit comments