class Dynflow::Director::ExecutionPlanManager
Attributes
execution_plan[R]
future[R]
Public Class Methods
new(world, execution_plan, future)
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 9 def initialize(world, execution_plan, future) @world = Type! world, World @execution_plan = Type! execution_plan, ExecutionPlan @future = Type! future, Concurrent::Edge::Future @running_steps_manager = RunningStepsManager.new(world) unless [:planned, :paused].include? execution_plan.state raise "execution_plan is not in pending or paused state, it's #{execution_plan.state}" end execution_plan.execution_history.add('start execution', @world.id) execution_plan.update_state(:running) end
Public Instance Methods
done?()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 58 def done? (!@run_manager || @run_manager.done?) && (!@finalize_manager || @finalize_manager.done?) end
event(event)
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 50 def event(event) Type! event, Event unless event.execution_plan_id == @execution_plan.id raise "event #{event.inspect} doesn't belong to plan #{@execution_plan.id}" end @running_steps_manager.event(event) end
prepare_next_step(step)
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 27 def prepare_next_step(step) StepWorkItem.new(execution_plan.id, step).tap do |work| @running_steps_manager.add(step, work) end end
start()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 22 def start raise "The future was already set" if @future.completed? start_run or start_finalize or finish end
terminate()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 62 def terminate @running_steps_manager.terminate end
what_is_next(work)
click to toggle source
@return [Array<WorkItem>] of Work items to continue with
# File lib/dynflow/director/execution_plan_manager.rb, line 34 def what_is_next(work) Type! work, WorkItem case work when StepWorkItem step = work.step execution_plan.steps[step.id] = step suspended, work = @running_steps_manager.done(step) work = compute_next_from_step(step) unless suspended work when FinalizeWorkItem raise "Finalize work item without @finalize_manager ready" unless @finalize_manager finish end end
Private Instance Methods
compute_next_from_step(step)
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 68 def compute_next_from_step(step) raise "run manager not set" unless @run_manager raise "run manager already done" if @run_manager.done? next_steps = @run_manager.what_is_next(step) if @run_manager.done? start_finalize or finish else next_steps.map { |s| prepare_next_step(s) } end end
finish()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 99 def finish execution_plan.execution_history.add('finish execution', @world.id) @execution_plan.update_state(execution_plan.error? ? :paused : :stopped) return no_work end
no_work()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 80 def no_work raise "No work but not done" unless done? [] end
start_finalize()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 92 def start_finalize return if execution_plan.finalize_flow.empty? raise 'finalize phase already started' if @finalize_manager @finalize_manager = SequentialManager.new(@world, execution_plan) [FinalizeWorkItem.new(execution_plan.id, @finalize_manager)] end
start_run()
click to toggle source
# File lib/dynflow/director/execution_plan_manager.rb, line 85 def start_run return if execution_plan.run_flow.empty? raise 'run phase already started' if @run_manager @run_manager = FlowManager.new(execution_plan, execution_plan.run_flow) @run_manager.start.map { |s| prepare_next_step(s) }.tap { |a| raise if a.empty? } end