Class: MedPipe::PipelineTask::PlanUpdater

Inherits:
Object
  • Object
show all
Defined in:
lib/med_pipe/pipeline_task/plan_updater.rb

Instance Method Summary collapse

Constructor Details

#initialize(save: false) ⇒ PlanUpdater

Returns a new instance of PlanUpdater.

Parameters:

  • save (Boolean) (defaults to: false) —

    trueの場合、Planを保存する。finishにするために更新が走るためここで保存しないことをdefaultにしている



5
6
7
 
# File 'lib/med_pipe/pipeline_task/plan_updater.rb', line 5

def initialize(save: false)
  @save = save
end

Instance Method Details

#call(context, input) {|inputをそのまま流す| ... } ⇒ Object

Parameters:

  • context (Hash)
  • input (Enumerable<Array<Object>>)

Yield Parameters:

  • inputをそのまま流す (Enumerable<Array<Object>>) 


12
13
14
15
 
# File 'lib/med_pipe/pipeline_task/plan_updater.rb', line 12

def call(context, input)
  update_plan(context)
  block_given? ? yield(input) : input
end