Method add_edge

core/src/graph/workflow_graph.rs:189–209

Add an edge between two nodes

(&mut self, from: NodeId, to: NodeId, edge: WorkflowEdge)

    /// Add an edge between two nodes
    pub fn add_edge(&mut self, from: NodeId, to: NodeId, edge: WorkflowEdge) -> GraphBitResult<()> {
        let from_index = self
            .node_map
            .get(&from)
            .ok_or_else(|| GraphBitError::graph(format!("Source node {from} not found")))?;

        let to_index = self
            .node_map
            .get(&to)
            .ok_or_else(|| GraphBitError::graph(format!("Target node {to} not found")))?;

        self.graph.add_edge(*from_index, *to_index, edge.clone());
        self.edges.push((from.clone(), to.clone(), edge));
        self.outgoing.entry(from.clone()).or_default().push(to.clone());
        self.incoming.entry(to.clone()).or_default().push(from.clone());

        // Invalidate caches since graph structure changed
        self.invalidate_caches();

        Ok(())
    }

    /// Remove a node from the graph
    pub fn remove_node(&mut self, node_id: &NodeId) -> GraphBitResult<()> {