lib/sidekiq/throttled/fetch.rb in sidekiq-throttled-0.15.1 vs lib/sidekiq/throttled/fetch.rb in sidekiq-throttled-0.16.0

@@ -20,10 +20,14 @@
         # @return [void]
         def bulk_requeue(units, _options)
           return if units.empty?
 
           Sidekiq.logger.debug { "Re-queueing terminated jobs" }
-          Sidekiq.redis { |conn| conn.pipelined { units.each(&:requeue) } }
+          Sidekiq.redis do |conn|
+            conn.pipelined do |pipeline|
+              units.each { |unit| unit.requeue(pipeline) }
+            end
+          end
           Sidekiq.logger.info("Pushed #{units.size} jobs back to Redis")
         rescue => e
           Sidekiq.logger.warn("Failed to requeue #{units.size} jobs: #{e}")
         end
       end