lib/tally/sweeper.rb in tally-1.0.1 vs lib/tally/sweeper.rb in tally-1.0.2

@@ -21,12 +21,12 @@
     end
 
     def sweep!
       Tally.redis do |conn|
         purgeable_keys.in_groups_of(25, fill_with = nil).each do |group|
-          conn.pipelined do
+          conn.pipelined do |pipeline|
             group.each do |key|
-              conn.del(key)
+              pipeline.del(key)
             end
           end
         end
       end
     end