Class: Ductr::Store::PipelineSerializer::SerializedPipelineStep

Inherits:
Struct
  • Object
show all
Defined in:
lib/ductr/store/pipeline_serializer.rb,
lib/ductr/store/pipeline_serializer.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(jobs, done) ⇒ SerializedPipelineStep

Returns a new instance of SerializedPipelineStep.

Parameters:

  • jobs (Array<Job>) —

    The step’s jobs

  • done (Boolean) —

    The step’s fiber state



15
16
17
18
 
# File 'lib/ductr/store/pipeline_serializer.rb', line 15

def initialize(jobs, done)
  @jobs = jobs
  @done = done
end

Instance Attribute Details

#done ⇒ Boolean (readonly)

Returns The step’s fiber state.

Returns:

  • (Boolean) —

    The step’s fiber state



10
11
12
13
14
15
16
17
18
19
 
# File 'lib/ductr/store/pipeline_serializer.rb', line 10

class SerializedPipelineStep < Struct
  #
  # @param [Array<Job>] jobs The step's jobs
  # @param [Boolean] done The step's fiber state
  #
  def initialize(jobs, done)
    @jobs = jobs
    @done = done
  end
end

#jobs ⇒ Array<Job> (readonly)

Returns The step’s jobs.

Returns:

  • (Array<Job>) —

    The step’s jobs



10
11
12
13
14
15
16
17
18
19
 
# File 'lib/ductr/store/pipeline_serializer.rb', line 10

class SerializedPipelineStep < Struct
  #
  # @param [Array<Job>] jobs The step's jobs
  # @param [Boolean] done The step's fiber state
  #
  def initialize(jobs, done)
    @jobs = jobs
    @done = done
  end
end

Instance Method Details

#done? ⇒ Boolean

Check if the step is done.

Returns:

  • (Boolean) —

    True if the step is done



82
83
84
 
# File 'lib/ductr/store/pipeline_serializer.rb', line 82

def done?
  done
end