lib/sidekiq/api.rb in sidekiq-6.0.0.pre1 vs lib/sidekiq/api.rb in sidekiq-6.0.0

@@ -84,18 +84,18 @@
         sscan(conn, "queues")
       }
 
       pipe2_res = Sidekiq.redis { |conn|
         conn.pipelined do
-          processes.each {|key| conn.hget(key, "busy") }
-          queues.each {|queue| conn.llen("queue:#{queue}") }
+          processes.each { |key| conn.hget(key, "busy") }
+          queues.each { |queue| conn.llen("queue:#{queue}") }
         end
       }
 
       s = processes.size
       workers_size = pipe2_res[0...s].map(&:to_i).inject(0, &:+)
-      enqueued     = pipe2_res[s..-1].map(&:to_i).inject(0, &:+)
+      enqueued = pipe2_res[s..-1].map(&:to_i).inject(0, &:+)
 
       default_queue_latency = if (entry = pipe1_res[6].first)
         job = begin
                 Sidekiq.load_json(entry)
               rescue
@@ -120,11 +120,11 @@
         enqueued: enqueued,
       }
     end
 
     def reset(*stats)
-      all   = %w[failed processed]
+      all = %w[failed processed]
       stats = stats.empty? ? all : all & stats.flatten.compact.map(&:to_s)
 
       mset_args = []
       stats.each do |stat|
         mset_args << "stat:#{stat}"
@@ -272,11 +272,11 @@
       page = 0
       page_size = 50
 
       loop do
         range_start = page * page_size - deleted_size
-        range_end   = range_start + page_size - 1
+        range_end = range_start + page_size - 1
         entries = Sidekiq.redis { |conn|
           conn.lrange @rname, range_start, range_end
         }
         break if entries.empty?
         page += 1
@@ -561,11 +561,11 @@
       page = -1
       page_size = 50
 
       loop do
         range_start = page * page_size + offset_size
-        range_end   = range_start + page_size - 1
+        range_end = range_start + page_size - 1
         elements = Sidekiq.redis { |conn|
           conn.zrange name, range_start, range_end, with_scores: true
         }
         break if elements.empty?
         page -= 1
@@ -711,11 +711,11 @@
     end
   end
 
   ##
   # Enumerates the set of Sidekiq processes which are actively working
-  # right now.  Each process send a heartbeat to Redis every 5 seconds
+  # right now.  Each process sends a heartbeat to Redis every 5 seconds
   # so this set should be relatively accurate, barring network partitions.
   #
   # Yields a Sidekiq::Process.
   #
   class ProcessSet
@@ -788,10 +788,10 @@
     # Returns the identity of the current cluster leader or "" if no leader.
     # This is a Sidekiq Enterprise feature, will always return "" in Sidekiq
     # or Sidekiq Pro.
     def leader
       @leader ||= begin
-        x = Sidekiq.redis {|c| c.get("dear-leader") }
+        x = Sidekiq.redis { |c| c.get("dear-leader") }
         # need a non-falsy value so we can memoize
         x ||= ""
         x
       end
     end