pub async fn execute_steps_parallel(
executor: Arc<dyn AgentExecutor>,
specs: Vec<AgentStepSpec>,
event_tx: Option<Sender<AgentEvent>>,
) -> Vec<StepOutcome>Expand description
Fan specs out across the executor, bounded by its
concurrency_hint, preserving input
order. A panicked branch becomes a failed StepOutcome without dropping
the others.
This is the barrier (parallel) primitive — it awaits every step. Later
combinators (pipeline, phases) build on the same seam.