Method connect

python/src/workflow/workflow.rs:33–71

(&mut self, from_id: String, to_id: String)

    }

    fn connect(&mut self, from_id: String, to_id: String) -> PyResult<()> {
        // If the string is a literal UUID (`add_node` return values), parse it first so a node
        // *name* that equals another node's UUID cannot hijack resolution. Otherwise resolve by
        // human-readable node name. (NodeId::from_string accepts any string via v5 — do not use
        // that path for names.)
        let from_node_id = if Uuid::parse_str(from_id.trim()).is_ok() {
            NodeId::from_string(&from_id).map_err(to_py_runtime_error)?
        } else if let Some(id) = self.inner.graph.get_node_id_by_name(&from_id) {
            id
        } else {
            return Err(PyErr::new::<pyo3::exceptions::PyValueError, _>(format!(
                "Source node {} not found",
                from_id
            )));
        };

        let to_node_id = if Uuid::parse_str(to_id.trim()).is_ok() {
            NodeId::from_string(&to_id).map_err(to_py_runtime_error)?
        } else if let Some(id) = self.inner.graph.get_node_id_by_name(&to_id) {
            id
        } else {
            return Err(PyErr::new::<pyo3::exceptions::PyValueError, _>(format!(
                "Target node {} not found",
                to_id
            )));
        };

        self.inner
            .connect_nodes(from_node_id, to_node_id, WorkflowEdge::data_flow())
            .map_err(|e| {
                let error_msg = e.to_string();
                if error_msg.contains("not found") || error_msg.contains("Target node") {
                    PyErr::new::<pyo3::exceptions::PyValueError, _>(error_msg)
                } else {
                    to_py_runtime_error(e)
                }
            })?;
        Ok(())
    }

    fn validate(&self) -> PyResult<()> {
        self.inner.validate().map_err(to_py_runtime_error)?;