diff --git a/lib/job-iteration/iteration.rb b/lib/job-iteration/iteration.rb index 2ee33d9d..6f689393 100644 --- a/lib/job-iteration/iteration.rb +++ b/lib/job-iteration/iteration.rb @@ -72,11 +72,6 @@ def perform(*params) # @private interruptible_perform(*params) end - def retry_job(*) - super unless @retried - @retried = true - end - private def enumerator_builder @@ -150,7 +145,9 @@ def reenqueue_iteration_job self.times_interrupted += 1 self.already_in_queue = true if respond_to?(:already_in_queue=) - retry_job + + enqueue unless @retried + @retried = true end def adjust_total_time