lib/rocket_job/batch/worker.rb in rocketjob-5.3.2 vs lib/rocket_job/batch/worker.rb in rocketjob-5.3.3

@@ -44,10 +44,10 @@
               # Grab a slice before checking the throttle to reduce concurrency race condition.
               return true if slice.fail_on_exception!(re_raise_exceptions) { rocket_job_batch_throttled?(slice, worker) }
               next if slice.failed?
 
               slice.fail_on_exception!(re_raise_exceptions) { rocket_job_process_slice(slice) }
-            elsif record_count && rocket_job_batch_complete?(worker.name)
+            elsif record_count && fail_on_exception!(re_raise_exceptions) { rocket_job_batch_complete?(worker.name) }
               return false
             else
               logger.debug "No more work available for this job"
               worker.add_to_current_filter(throttle_filter_id)
               return true