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::Promises::ResolvableFuture
  @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, step.queue).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.resolved?
  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, execution_plan.finalize_steps.first.queue)]
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