Skip to content

Commit

Permalink
forgot to save first
Browse files Browse the repository at this point in the history
  • Loading branch information
mperham committed Jun 27, 2024
1 parent 4c2302e commit 9ebabc3
Showing 1 changed file with 0 additions and 3 deletions.
3 changes: 0 additions & 3 deletions lib/sidekiq/job/iterable.rb
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@ def initialize

@_executions = 0
@_cursor = nil
@_interrupted = 0
@_start_time = nil
@_runtime = 0
end
Expand Down Expand Up @@ -154,7 +153,6 @@ def fetch_previous_iteration_state
unless state.empty?
@_executions = state["ex"].to_i
@_cursor = Sidekiq.load_json(state["c"])
@_interrupted = state["int"].to_i
@_runtime = state["rt"].to_f
end
end
Expand Down Expand Up @@ -192,7 +190,6 @@ def iterate_with_enumerator(enumerator, arguments)
end

def reenqueue_iteration_job
@_interrupted += 1
flush_state
logger.debug { "Interrupting job (cursor=#{@_cursor.inspect})" }

Expand Down

0 comments on commit 9ebabc3

Please sign in to comment.