Struct AgentExecutor 

pub struct AgentExecutor { /* private fields */ }

An Executor that runs an SupportsAgentRun over the incoming conversation and appends the agent’s reply. Rust analogue of AgentExecutor.

Implementations

impl AgentExecutor

pub fn new( id: impl Into<String>, agent: Arc<dyn SupportsAgentRun>, ) -> AgentExecutor

Wrap agent as an executor with the given id.

pub fn with_output(self, emit_output: bool) -> AgentExecutor

When set, the executor yields the running conversation as a workflow output. Unless Self::with_also_send is also set, this replaces forwarding the conversation downstream (the pre-designation default: a pipeline’s terminal executor only yields, it has nothing downstream to send to).

pub fn with_also_send(self, also_send: bool) -> AgentExecutor

When set, the executor forwards the conversation downstream via WorkflowContext::send_message even if Self::with_output is also set (rather than the exclusive-or default). Needed whenever an interior (non-terminal) participant is designated as an output or intermediate-output source and must still hand the conversation to the next stage / the fan-in barrier.

Trait Implementations

impl Executor for AgentExecutor

fn id(&self) -> &str

A unique id for this executor within the workflow.

fn execute<'life0, 'async_trait>( &'life0 self, message: Value, ctx: WorkflowContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, AgentExecutor: 'async_trait,

Handle an incoming message.

fn snapshot_state<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Option<Value>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Capture serializable state for checkpointing.

fn restore_state<'life0, 'async_trait>( &'life0 self, _state: Value, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Restore state previously produced by Executor::snapshot_state.