pub struct TaskLaunchService { /* private fields */ }Expand description
Domain service that compiles, links, and runs a Blueprint’s flow to
completion through the Engine. See the module doc for the full
responsibility list.
Implementations§
Source§impl TaskLaunchService
impl TaskLaunchService
Sourcepub fn new(engine: Engine, compiler: Compiler) -> Self
pub fn new(engine: Engine, compiler: Compiler) -> Self
Build a service bound to one Engine and one Compiler.
Sourcepub fn with_externs(self, externs: Arc<dyn Externs + Send + Sync>) -> Self
pub fn with_externs(self, externs: Arc<dyn Externs + Send + Sync>) -> Self
Replace the call_extern registry (builder style). Entries MUST be
pure functions — no side effects, no flow control; effectful work
belongs to Step / agents, not externs (flow-ir canonical contract).
Sourcepub fn with_binding_provider(
self,
provider: Arc<dyn AgentBindingProvider>,
) -> Self
pub fn with_binding_provider( self, provider: Arc<dyn AgentBindingProvider>, ) -> Self
Inject the execution-environment binding provider. Platform plugins and Operator/MainAI implementations use this same interface; Core retains receipt validation and digest ownership.
Sourcepub fn with_legacy_worker_binding_policy(
self,
policy: LegacyWorkerBindingPolicy,
) -> Self
pub fn with_legacy_worker_binding_policy( self, policy: LegacyWorkerBindingPolicy, ) -> Self
Configure the migration gate for deprecated profile.worker_binding.
Sourcepub async fn launch(
&self,
input: TaskLaunchInput,
) -> Result<TaskLaunchOutput, TaskLaunchError>
pub async fn launch( &self, input: TaskLaunchInput, ) -> Result<TaskLaunchOutput, TaskLaunchError>
Run the Blueprint’s flow to completion and return the final
ctx.
Failure paths:
compiler.compilefailure →TaskLaunchError::Compile.engine.attachfailure →TaskLaunchError::Engine.- A
Stepinsideflow evalproducing a dispatcher error, or a sub-flow raising, →TaskLaunchError::FlowEval. There is no silent partial-success completion; failures always propagate.
Auto Trait Implementations§
impl !RefUnwindSafe for TaskLaunchService
impl !UnwindSafe for TaskLaunchService
impl Freeze for TaskLaunchService
impl Send for TaskLaunchService
impl Sync for TaskLaunchService
impl Unpin for TaskLaunchService
impl UnsafeUnpin for TaskLaunchService
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more