Update stopping value every heartbeat

lib/sidekiq/api.rb

@@ -674,13 +674,13 @@ def each
         # you'll be happier this way
         result = conn.pipelined do
           procs.each do |key|
-            conn.hmget(key, 'info', 'busy', 'beat')
+            conn.hmget(key, 'info', 'busy', 'beat', 'quiet')
           end
         end
 
-        result.each do |info, busy, at_s|
+        result.each do |info, busy, at_s, quiet|
           hash = Sidekiq.load_json(info)
-          yield Process.new(hash.merge('busy' => busy.to_i, 'beat' => at_s.to_f))
+          yield Process.new(hash.merge('busy' => busy.to_i, 'beat' => at_s.to_f, 'quiet' => quiet))
         end
       end
 
@@ -738,9 +738,9 @@ def stop!
     def dump_threads
       signal('TTIN')
     end
-    
+
     def stopping?
-      self['stopping']
+      self['quiet'] == 'true'
     end
 
     private

lib/sidekiq/launcher.rb

@@ -95,7 +95,7 @@ def ❤(key, json)
         _, _, _, msg = Sidekiq.redis do |conn|
           conn.pipelined do
             conn.sadd('processes', key)
-            conn.hmset(key, 'info', json, 'busy', Processor::WORKER_STATE.size, 'beat', Time.now.to_f)
+            conn.hmset(key, 'info', json, 'busy', Processor::WORKER_STATE.size, 'beat', Time.now.to_f, 'quiet', @done)
             conn.expire(key, 60)
             conn.rpop("#{key}-signals")
           end
@@ -127,8 +127,7 @@ def start_heartbeat
         'concurrency' => @options[:concurrency],
         'queues' => @options[:queues].uniq,
         'labels' => @options[:labels],
-        'identity' => k,
-        'stopping' => @done
+        'identity' => k
       }
       # this data doesn't change so dump it to a string
       # now so we don't need to dump it every heartbeat.