From 4d530b8af744d5d0da54d181255434c59ef7cbcf Mon Sep 17 00:00:00 2001 From: Chris Wanstrath Date: Thu, 22 Sep 2011 16:46:47 -0700 Subject: [PATCH] tweak --- lib/resque/worker.rb | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/lib/resque/worker.rb b/lib/resque/worker.rb index cbc0714db..32c450d99 100644 --- a/lib/resque/worker.rb +++ b/lib/resque/worker.rb @@ -35,17 +35,17 @@ def self.working names.map! { |name| "worker:#{name}" } - reportedly_working = begin - redis.mapped_mget(*names).reject do |key, value| + reportedly_working = {} + + begin + reportedly_working = redis.mapped_mget(*names).reject do |key, value| value.nil? || value.empty? end rescue Redis::Distributed::CannotDistribute - result = {} names.each do |name| value = redis.get name - result[name] = value unless value.nil? || value.empty? + reportedly_working[name] = value unless value.nil? || value.empty? end - result end reportedly_working.keys.map do |key|