Sha256: f4fcd3511a52780b23f6650c8712c98284bd98818cf9d9f9b144b0b338831277
Contents?: true
Size: 1.16 KB
Versions: 20
Compression:
Stored size: 1.16 KB
Contents
module Dynflow
module Executors
class Abstract
include Algebrick::TypeCheck
attr_reader :world, :logger
def initialize(world)
@world = Type! world, World
@logger = world.logger
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
def execute(execution_plan_id, finished = Concurrent.future, wait_for_acceptance = true)
raise NotImplementedError
end
def event(execution_plan_id, step_id, event, future = Concurrent.future)
raise NotImplementedError
end
def terminate(future = Concurrent.future)
raise NotImplementedError
end
def execution_status(execution_plan_id = nil)
raise NotImplementedError
end
# @return [Concurrent::Edge::Future]
def initialized
raise NotImplementedError
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems