Class: MedPipe::PipelineRunnerBase

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

Overview

PipelinePlanConsumerに渡すPipelineRunnerの作成を補助するクラス call(pipeline_plan)さえ実装していれば良いため、必ずしも本クラスを使う必要はありません。

Instance Method Summary collapse

Instance Method Details

#build_pipeline(pipeline_plan) ⇒ Object 



13
14
15
 
# File 'lib/med_pipe/pipeline_runner_base.rb', line 13

def build_pipeline(pipeline_plan)
  raise NotImplementedError("#{pipeline_plan.name}に対応するPipelineを作成する処理をサブクラスで実装してください")
end

#call(pipeline_plan) ⇒ Object

PipelinePlanConsumerから呼び出されるメソッド



7
8
9
10
11
 
# File 'lib/med_pipe/pipeline_runner_base.rb', line 7

def call(pipeline_plan)
  pipeline = build_pipeline(pipeline_plan)
  context = { plan: pipeline_plan }
  pipeline.run(context)
end