diff --git a/lib/job-iteration/iteration.rb b/lib/job-iteration/iteration.rb index 7f8a5180..7d2e1dd3 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 defined?(@retried) && @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 @enqueued + @enqueued = true end def adjust_total_time