lib/resque/scheduler/locking.rb in resque-scheduler-4.3.1 vs lib/resque/scheduler/locking.rb in resque-scheduler-4.4.0

@@ -74,11 +74,11 @@
         master_lock.release!
       end
 
       def release_master_lock
         master_lock.release
-      rescue Errno::EAGAIN, Errno::ECONNRESET, Redis::CannotConnectError
+      rescue *INTERMITTENT_ERRORS
         @master_lock = nil
       end
 
       private
 
@@ -95,10 +95,10 @@
         lock_prefix += ':' if lock_prefix != ''
         "#{Resque.redis.namespace}:#{lock_prefix}resque_scheduler_master_lock"
       end
 
       def redis_master_version
-        Resque.redis.info['redis_version'].to_f
+        Resque.data_store.redis.info['redis_version'].to_f
       end
     end
   end
 end