Struct AgentApprovalExecutor 

pub struct AgentApprovalExecutor { /* private fields */ }

An Executor that runs an SupportsAgentRun over the incoming conversation, then pauses for human approval of its reply before forwarding it downstream. Rust analogue of AgentApprovalExecutor.

A non-empty human response is treated as revision feedback: the agent is re-invoked with the feedback appended, and a new approval request is raised — repeating until an empty (approving) response arrives.

Implementations

impl AgentApprovalExecutor

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

Wrap agent in a post-agent approval gate with the given executor id.

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

When set, yield the approved conversation as a workflow output. See AgentExecutor::with_output.

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

When set, forward the approved conversation downstream even if Self::with_output is also set. See AgentExecutor::with_also_send.

Trait Implementations

impl Executor for AgentApprovalExecutor

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, AgentApprovalExecutor: '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.