lib/rocket_job/batch/worker.rb in rocketjob-5.3.0 vs lib/rocket_job/batch/worker.rb in rocketjob-5.3.1

@@ -108,12 +108,10 @@
           end
         end
         servers
       end
 
-      private
-
       def rocket_job_batch_throttled?(slice, worker)
         filter = self.class.rocket_job_batch_throttles.matching_filter(self, slice)
         return false unless filter
 
         # Restore retrieved slice so that other workers can process it later.
@@ -148,10 +146,10 @@
         count = 0
         RocketJob::Sliced::Writer::Output.collect(self, slice) do |writer|
           records = slice.records
 
           # Skip records already processed, if any.
-          #slice.processing_record_number ||= 0
+          # slice.processing_record_number ||= 0
           # TODO: Must append to existing output slices before this can be enabled.
           # if !collect_output && (slice.processing_record_number > 1)
           #   records = records[slice.processing_record_number - 1..-1]
           # end
           # Until the changes above have been implemented, reprocess all records in the slice.