lib/sidekiq/limit_fetch/global/monitor.rb in sidekiq-limit_fetch-1.6 vs lib/sidekiq/limit_fetch/global/monitor.rb in sidekiq-limit_fetch-1.7

@@ -35,11 +35,13 @@
         it.keys(PROCESSOR_NAMESPACE + '*').each do |processor|
           processor.sub! PROCESSOR_NAMESPACE, ''
           next if it.get heartbeat_key processor
 
           it.del processor_key processor
-          it.keys('limit_fetch:busy:*').each do |queue|
-            it.lrem queue, 0, processor
+          %w(limit_fetch:probed:* limit_fetch:busy:*).each do |pattern|
+            it.keys(pattern).each do |queue|
+              it.lrem queue, 0, processor
+            end
           end
         end
       end
     end