Struct ParallelSubgraphs 

pub struct ParallelSubgraphs { /* private fields */ }

Parallel subgraph executor - runs multiple subgraphs concurrently

Implementations

impl ParallelSubgraphs

pub fn new() -> Self

Create a new parallel subgraph executor

pub fn add( self, name: impl Into<String>, graph: Graph, mapping: StateMapping, ) -> Self

Add a subgraph

pub fn with_strategy(self, strategy: MergeStrategy) -> Self

Set merge strategy

pub async fn execute(&self, state: &GraphState) -> Result<GraphState, CrewError>

Execute all subgraphs in parallel

Trait Implementations

impl Default for ParallelSubgraphs

fn default() -> Self

Returns the “default value” for a type.

impl NodeFn for ParallelSubgraphs

fn call<'life0, 'async_trait>( &'life0 self, state: GraphState, ) -> Pin<Box<dyn Future<Output = Result<GraphState, CrewError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the node and return updated state