MCPcopy Index your code
hub / github.com/AI45Lab/Code / parallel

Method parallel

core/src/orchestration/workflow.rs:226–228  ·  view source on GitHub ↗

Barrier fan-out. Bounded by the executor's [`concurrency_hint`](AgentExecutor::concurrency_hint); input order is preserved and a panicked branch becomes a failed [`StepOutcome`].

(&self, specs: Vec<AgentStepSpec>)

Source from the content-addressed store, hash-verified

224 /// [`concurrency_hint`](AgentExecutor::concurrency_hint); input order is
225 /// preserved and a panicked branch becomes a failed [`StepOutcome`].
226 pub async fn parallel(&self, specs: Vec<AgentStepSpec>) -> Vec<StepOutcome> {
227 execute_steps_parallel(Arc::clone(&self.executor), specs, self.step_events.clone()).await
228 }
229
230 /// A *named* barrier and a resume boundary.
231 ///

Callers 2

phaseMethod · 0.45

Calls 2

execute_steps_parallelFunction · 0.85
cloneMethod · 0.45

Tested by

no test coverage detected