lib/sidekiq/limit_fetch/global/monitor.rb in sidekiq-limit_fetch-4.3.1 vs lib/sidekiq/limit_fetch/global/monitor.rb in sidekiq-limit_fetch-4.3.2

@@ -31,11 +31,11 @@
       end
     end
 
     def remove_old_processes!
       Sidekiq.redis do |it|
-        old_processes.each {|process| it.srem PROCESS_SET, process }
+        old_processes.each {|process| it.srem PROCESS_SET, [process] }
       end
     end
 
     def handle_dynamic_queues
       queues = Sidekiq::LimitFetch::Queues
@@ -46,10 +46,10 @@
 
     def update_heartbeat(ttl)
       Sidekiq.redis do |it|
         it.multi do |pipeline|
           pipeline.set heartbeat_key, true
-          pipeline.sadd PROCESS_SET, Selector.uuid
+          pipeline.sadd PROCESS_SET, [Selector.uuid]
           pipeline.expire heartbeat_key, ttl
         end
       end
     end