class Dynflow::Executors::Abstract

Attributes

logger[R]
world[R]

Public Class Methods

new(world) click to toggle source
# File lib/dynflow/executors/abstract.rb, line 7
def initialize(world)
  @world  = Type! world, World
  @logger = world.logger
end

Public Instance Methods

event(execution_plan_id, step_id, event, future = Concurrent.future) click to toggle source
# File lib/dynflow/executors/abstract.rb, line 22
def event(execution_plan_id, step_id, event, future = Concurrent.future)
  raise NotImplementedError
end
execute(execution_plan_id, finished = Concurrent.future, wait_for_acceptance = true) click to toggle source

@param execution_plan_id [String] id of execution plan @param finished [Concurrent::Edge::Future] @param wait_for_acceptance [TrueClass|FalseClass] should the executor confirm receiving the event, disable if calling executor from within executor @return [Concurrent::Edge::Future] @raise when execution_plan_id is not accepted

# File lib/dynflow/executors/abstract.rb, line 18
def execute(execution_plan_id, finished = Concurrent.future, wait_for_acceptance = true)
  raise NotImplementedError
end
initialized() click to toggle source

@return [Concurrent::Edge::Future]

# File lib/dynflow/executors/abstract.rb, line 31
def initialized
  raise NotImplementedError
end
terminate(future = Concurrent.future) click to toggle source
# File lib/dynflow/executors/abstract.rb, line 26
def terminate(future = Concurrent.future)
  raise NotImplementedError
end