Struct DagAgent 

pub struct DagAgent<P: LlmProvider + 'static> { /* private fields */ }

A directed acyclic graph of agents.

Implementations

impl<P: LlmProvider + 'static> DagAgent<P>

pub fn builder() -> DagAgentBuilder<P>

Create a new DagAgentBuilder.

Add nodes with .node("name", agent) and edges with .edge("from", "to"). The builder validates the graph is acyclic and that all edge endpoints reference declared nodes.

Example

A diamond DAG: planner fans out to two workers that converge into a synthesizer.

use std::sync::Arc;
use heartbit_core::{
    AgentRunner, AnthropicProvider, BoxedProvider, DagAgent,
};

let provider = Arc::new(BoxedProvider::new(AnthropicProvider::new(
    "sk-...",
    "claude-sonnet-4-20250514",
)));
let make = |prompt: &str| {
    AgentRunner::builder(provider.clone())
        .system_prompt(prompt)
        .build()
        .expect("agent build")
};

let dag = DagAgent::builder()
    .node("plan", make("Outline the question."))
    .node("research", make("Answer the question."))
    .node("critique", make("Critique the proposed answer."))
    .node("synth", make("Combine research and critique."))
    .edge("plan", "research")
    .edge("plan", "critique")
    .edge("research", "synth")
    .edge("critique", "synth")
    .build()?;
let output = dag.execute("Should we use Rust?").await?;
println!("{}", output.result);

pub async fn execute(&self, task: &str) -> Result<AgentOutput, Error>

Execute the DAG. task is the input for all root nodes (in-degree 0). Returns aggregated output from all terminal nodes.

Trait Implementations

impl<P: LlmProvider + 'static> Debug for DagAgent<P>

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

Formats the value using the given formatter.

impl<P: LlmProvider + 'static> From<DagAgent<P>> for WorkflowRouter<P>

fn from(agent: DagAgent<P>) -> Self

Converts to this type from the input type.