We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4c2302e commit 9ebabc3Copy full SHA for 9ebabc3
lib/sidekiq/job/iterable.rb
@@ -28,7 +28,6 @@ def initialize
28
29
@_executions = 0
30
@_cursor = nil
31
- @_interrupted = 0
32
@_start_time = nil
33
@_runtime = 0
34
end
@@ -154,7 +153,6 @@ def fetch_previous_iteration_state
154
153
unless state.empty?
155
@_executions = state["ex"].to_i
156
@_cursor = Sidekiq.load_json(state["c"])
157
- @_interrupted = state["int"].to_i
158
@_runtime = state["rt"].to_f
159
160
@@ -192,7 +190,6 @@ def iterate_with_enumerator(enumerator, arguments)
192
190
193
191
194
def reenqueue_iteration_job
195
- @_interrupted += 1
196
flush_state
197
logger.debug { "Interrupting job (cursor=#{@_cursor.inspect})" }
198
0 commit comments