class ActiveJob::Continuation::Step

Active Job `Continuation` `Step`

Represents a step within a continuable job.

When a step is completed, it is recorded in the job’s continuation state. If the job is interrupted, it will be resumed from after the last completed step.

Steps also have an optional cursor that can be used to track progress within the step. If a job is interrupted during a step, the cursor will be saved and passed back when the job is resumed.

It is the responsibility of the code in the step to use the cursor correctly to resume from where it left off.

Attributes

cursor [R]

The cursor for the step.

initial_cursor [R]

job [R]

name [R]

The name of the step.

Public Class Methods

new (name, cursor, job:, resumed:)

Source

# File lib/active_job/continuation/step.rb, line 25
def initialize(name, cursor, job:, resumed:)
  @name = name.to_sym
  @initial_cursor = cursor
  @cursor = cursor
  @resumed = resumed
  @job = job
end

Public Instance Methods

advance! (from: nil)

Source

# File lib/active_job/continuation/step.rb, line 49
def advance!(from: nil)
  from = cursor if from.nil?

  begin
    to = from.succ
  rescue NoMethodError
    raise UnadvanceableCursorError, "Cursor class '#{from.class}' does not implement 'succ'"
  end

  set! to
end

Advance the cursor from the current or supplied value

The cursor will be advanced by calling the succ method on the cursor. An UnadvanceableCursorError error will be raised if the cursor does not implement succ.

advanced? ()

Source

# File lib/active_job/continuation/step.rb, line 67
def advanced?
  initial_cursor != cursor
end

Has the cursor been advanced during this job execution?

checkpoint! ()

Source

# File lib/active_job/continuation/step.rb, line 35
def checkpoint!
  job.checkpoint!
end

Check if the job should be interrupted, and if so raise an Interrupt exception. The job will be requeued for retry.

description ()

Source

# File lib/active_job/continuation/step.rb, line 75
def description
  "at '#{name}', cursor '#{cursor.inspect}'"
end

resumed? ()

Source

# File lib/active_job/continuation/step.rb, line 62
def resumed?
  @resumed
end

Has this step been resumed from a previous job execution?

set! (cursor)

Source

# File lib/active_job/continuation/step.rb, line 40
def set!(cursor)
  @cursor = cursor
  checkpoint!
end

Set the cursor and interrupt the job if necessary.

to_a ()

Source

# File lib/active_job/continuation/step.rb, line 71
def to_a
  [ name.to_s, cursor ]
end

class ActiveJob::Continuation::Step

Active Job Continuation Step

Active Job `Continuation` `Step`