Struct TaskAdapter 

pub struct TaskAdapter { /* private fields */ }

Adapts an Input=String orchestrator into a child agent consuming AgentTask (P2-5).

Bridges two orchestrator kinds: a real agent (PlanExecuteAgent / DeepResearchAgent, etc., Input=String) wrapped this way can be placed in a FanOutFanIn / SequentialPipeline that dispatches AgentTask. Takes the objective and feeds it to the inner orchestrator; when the task declares allowed_tools, the consumer (AgentExecutor, etc.) assembles the tool list from that allowlist — this adapter does not filter on its behalf.

Implementations

impl TaskAdapter

pub fn new( inner: Arc<dyn Orchestrator<Input = String, Output = String>>, ) -> Self

Wrap an Input=String orchestrator.

Trait Implementations

impl Orchestrator for TaskAdapter

type Input = AgentTask

Input type (usually a String objective/question).

type Output = String

Output type.

fn run_with_context<'life0, 'life1, 'async_trait>( &'life0 self, task: Self::Input, ctx: &'life1 RunContext, ) -> Pin<Box<dyn Future<Output = Result<Self::Output, AgentError>> + Send + 'async_trait>>

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

Execution entry point carrying the run context.