Skip to content

Commit fc5657c

Browse files
author
Gustavo Caso
committed
use enqueue instead of retry_job to reenqueue jobs
1 parent 55b4640 commit fc5657c

1 file changed

Lines changed: 3 additions & 6 deletions

File tree

lib/job-iteration/iteration.rb

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -72,11 +72,6 @@ def perform(*params) # @private
7272
interruptible_perform(*params)
7373
end
7474

75-
def retry_job(*)
76-
super unless defined?(@retried) && @retried
77-
@retried = true
78-
end
79-
8075
private
8176

8277
def enumerator_builder
@@ -150,7 +145,9 @@ def reenqueue_iteration_job
150145
self.times_interrupted += 1
151146

152147
self.already_in_queue = true if respond_to?(:already_in_queue=)
153-
retry_job
148+
149+
enqueue unless @enqueued
150+
@enqueued = true
154151
end
155152

156153
def adjust_total_time

0 commit comments

Comments
 (0)