Struct OperatorSpawner 

pub struct OperatorSpawner { /* private fields */ }

A SpawnerAdapter implementation that hands the dispatch off to an Arc<dyn Operator>.

OperatorSpawner itself does not inspect the operator’s kind — MainAi / Human / Automate / Composite all go through the same path, and the operator implementation absorbs the differences.

Position — the AgentSpec-axis Operator path

Use this type on the path that bakes a separate Operator backend into every AgentDef. For an AgentKind::Operator AgentDef, the OperatorSpawnerFactory produces one with OperatorSpawner::new(op, system_prompt, worker_binding) and places it in routes[agent_name]. Agents flowing in through the agent.md loader default to kind = Operator, so they land here.

This is now the only way a dispatch reaches an Operator. There used to be a paired Blueprint-global (session) axis, crate::middleware::OperatorDelegateMiddleware, which registered one backend on the session and applied it uniformly to every agent; when both were effective it sat at the outer end of the stack and bypassed inner.spawn, leaving this type inert. It was removed — it resolved its destination from the launch record rather than the Run’s seat (so a handover could not move it) and, having no per-agent spawner, could not render or bake an agent’s system_prompt. With one axis left, the exclusivity question it created goes away with it.

Implementations

impl OperatorSpawner

pub fn new( operator: Arc<dyn Operator>, system_prompt: Option<String>, worker_binding: Option<WorkerBinding>, ) -> Self

Binds an operator backend plus an optional compile-time system_prompt template (rendered per-spawn via render_system) and an optional compile-time-baked worker_binding.

Trait Implementations

impl SpawnerAdapter for OperatorSpawner

fn spawn<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, engine: &'life1 Engine, ctx: &'life2 Ctx, task_id: StepId, attempt: u32, token: CapToken, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Worker>, SpawnError>> + Send + 'async_trait>>

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

Spawn one attempt as a worker. Returns Box<dyn Worker>.