# File lib/dynflow/executors/abstract.rb, line 7 def initialize(world) @world = Type! world, World @logger = world.logger end
# File lib/dynflow/executors/abstract.rb, line 22 def event(execution_plan_id, step_id, event, future = Concurrent.future) raise NotImplementedError end
@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
@return [Concurrent::Edge::Future]
# File lib/dynflow/executors/abstract.rb, line 31 def initialized raise NotImplementedError end
# File lib/dynflow/executors/abstract.rb, line 26 def terminate(future = Concurrent.future) raise NotImplementedError end