Skip to main content

WorkflowRunner

Struct WorkflowRunner 

Source
pub struct WorkflowRunner<'a> { /* private fields */ }
Expand description

Builder-style runner for YAML workflow execution.

This is the preferred additive API for configuring workflow runs while keeping legacy run_* helpers as compatibility adapters.

Implementations§

Source§

impl<'a> WorkflowRunner<'a>

Source

pub fn from_file(workflow_path: &'a Path) -> Self

Source

pub fn from_workflow(workflow: &'a YamlWorkflow) -> Self

Source

pub fn with_input(self, workflow_input: &'a Value) -> Self

Source

pub fn with_email_text(self, email_text: &'a str) -> Self

Source

pub fn with_executor(self, executor: &'a dyn YamlWorkflowLlmExecutor) -> Self

Source

pub fn with_client(self, client: &'a SimpleAgentsClient) -> Self

Source

pub fn with_custom_worker( self, custom_worker: Option<&'a dyn YamlWorkflowCustomWorkerExecutor>, ) -> Self

Source

pub fn with_event_sink( self, event_sink: Option<&'a dyn YamlWorkflowEventSink>, ) -> Self

Source

pub fn with_typed_event_sink( self, typed_event_sink: Option<&'a dyn YamlWorkflowTypedEventSink>, ) -> Self

Source

pub fn with_options(self, options: &'a YamlWorkflowRunOptions) -> Self

Source

pub async fn run(self) -> Result<YamlWorkflowRunOutput, YamlWorkflowRunError>

Source

pub async fn run_typed( self, ) -> Result<YamlWorkflowRunTypedOutput, YamlWorkflowRunError>

Execute the workflow and return the typed projection.

The typed output keeps only workflow identity, traversal, and node outputs. Legacy fields on YamlWorkflowRunOutput such as telemetry, timing, token counters, and email_text remain available via run().

Auto Trait Implementations§

§

impl<'a> Freeze for WorkflowRunner<'a>

§

impl<'a> !RefUnwindSafe for WorkflowRunner<'a>

§

impl<'a> Send for WorkflowRunner<'a>

§

impl<'a> Sync for WorkflowRunner<'a>

§

impl<'a> Unpin for WorkflowRunner<'a>

§

impl<'a> UnsafeUnpin for WorkflowRunner<'a>

§

impl<'a> !UnwindSafe for WorkflowRunner<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more