Struct ParallelNode 

pub struct ParallelNode {
    pub fail_fast: bool,
    pub min_success: Option<u32>,
    pub calls: Vec<AgentRef>,
    pub output: Option<String>,
    pub call_outputs: HashMap<String, String>,
    pub with: Vec<String>,
    pub call_with: HashMap<String, Vec<String>>,
    pub call_if: HashMap<String, (String, String)>,
    pub call_retries: HashMap<String, u32>,
}

Fields

fail_fast: bool

min_success: Option<u32>

calls: Vec<AgentRef>

output: Option<String>

Block-level output schema reference (applies to all calls unless overridden).

call_outputs: HashMap<String, String>

Per-call output schema overrides, keyed by index (as string) in calls. String keys are used because JSON object keys are always strings and serde_json cannot coerce them back to integer types on deserialization.

with: Vec<String>

Block-level prompt snippet references (applied to all calls).

call_with: HashMap<String, Vec<String>>

Per-call prompt snippet additions, keyed by index (as string) in calls.

call_if: HashMap<String, (String, String)>

Per-call if conditions keyed by index (as string) in calls. Value is (step_name, marker_name). Run the call only if that marker is present.

call_retries: HashMap<String, u32>

Per-call retry counts keyed by index (as string) in calls. 0 = no retries.

Trait Implementations

impl Clone for ParallelNode

fn clone(&self) -> ParallelNode

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ParallelNode

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ParallelNode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ParallelNode

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.