Method agent

core/src/orchestration/workflow.rs:209–221

Run a single step. A one-element barrier — reuses the panic isolation and placement of [`parallel`](Self::parallel) so one and many steps share a single code path.

(&self, spec: AgentStepSpec)

    /// placement of [`parallel`](Self::parallel) so one and many steps share a
    /// single code path.
    pub async fn agent(&self, spec: AgentStepSpec) -> StepOutcome {
        let task_id = spec.task_id.clone();
        let agent = spec.agent.clone();
        execute_steps_parallel(
            Arc::clone(&self.executor),
            vec![spec],
            self.step_events.clone(),
        )
        .await
        .into_iter()
        .next()
        .unwrap_or_else(|| StepOutcome::failed(task_id, agent, "step produced no outcome"))
    }

    /// Barrier fan-out. Bounded by the executor's
    /// [`concurrency_hint`](AgentExecutor::concurrency_hint); input order is