agentwerk 0.1.7

A minimal Rust crate that gives any application agentic capabilities.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

//! End-to-end: `Batch::run` runs several real-LLM agents concurrently. Guards concurrency capping and result correlation against a live provider.

use super::common;

use agentwerk::{Agent, Batch, ReadFileTool};

#[tokio::test]
async fn test() -> std::result::Result<(), Box<dyn std::error::Error>> {
    let (provider, model) = common::build_provider();

    let output_schema = serde_json::json!({
        "type": "object",
        "properties": {
            "summary": {
                "type": "string",
                "description": "One-sentence summary"
            }
        },
        "required": ["summary"]
    });

    let summarizer = Agent::new()
        .model_name(&model)
        .tool(ReadFileTool)
        .output_schema(output_schema)
        .max_turns(5);

    let files = ["Cargo.toml", "README.md", "CLAUDE.md"];
    let agents = files.iter().map(|file| {
        summarizer
            .clone()
            .name(format!("summarize-{file}"))
            .provider(provider.clone())
            .instruction_prompt(format!("Read and summarize: {file}"))
    });

    let results = Batch::new().concurrency(2).agents(agents).run().await;

    assert_eq!(results.len(), files.len());
    for result in &results {
        let output = result.as_ref().expect("agent failed");
        let json = output.response.as_ref().expect("missing structured output");
        assert!(
            json["summary"].is_string(),
            "{}: expected summary string",
            output.name
        );
    }

    common::print_result(results[0].as_ref().unwrap());

    Ok(())
}