serdes-ai-graph

Graph-based execution and multi-agent orchestration for serdes-ai

This crate provides graph-based workflow execution for SerdesAI:

• Graph builder for defining workflows
• BaseNode trait for custom nodes
• State management across nodes
• Conditional branching and loops
• Multi-agent orchestration

Installation

[dependencies]
serdes-ai-graph = "0.1"

Usage

use serdes_ai_graph::{Graph, BaseNode, NodeResult, GraphRunContext, GraphResult};
use async_trait::async_trait;

#[derive(Debug, Clone, Default)]
struct MyState {
    data: String,
}

struct ProcessNode;

#[async_trait]
impl BaseNode<MyState, (), String> for ProcessNode {
    fn name(&self) -> &str { "process" }
    
    async fn run(
        &self,
        ctx: &mut GraphRunContext<MyState, ()>,
    ) -> GraphResult<NodeResult<MyState, (), String>> {
        ctx.state.data = "processed".to_string();
        Ok(NodeResult::end(ctx.state.data.clone()))
    }
}

let graph = Graph::new()
    .node("process", ProcessNode)
    .entry("process")
    .build()?;

let result = graph.run(MyState::default(), ()).await?;

Part of SerdesAI

This crate is part of the SerdesAI workspace.

For most use cases, you should use the main serdes-ai crate which re-exports these types.

License

MIT License - see LICENSE for details.