agentwerk 0.1.1

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
54
55
56
57
58

mod common;

use agentwerk::{Agent, AgentPool, PoolStrategy, 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(&model)
        .tool(ReadFileTool)
        .output_schema(output_schema)
        .max_turns(5);

    let pool = AgentPool::new()
        .batch_size(2)
        .ordering(PoolStrategy::SpawnOrder);

    for file in &["Cargo.toml", "README.md", "CLAUDE.md"] {
        pool.spawn(
            summarizer
                .clone()
                .provider(provider.clone())
                .instruction_prompt(format!("Read and summarize: {file}")),
        )
        .await;
    }

    let results = pool.drain().await;

    assert_eq!(results.len(), 3);
    for (i, (_id, result)) in results.iter().enumerate() {
        let output = result.as_ref().expect(&format!("Agent {i} failed"));
        let json = output
            .response
            .as_ref()
            .expect(&format!("Agent {i} missing structured output"));
        assert!(
            json["summary"].is_string(),
            "Agent {i}: expected summary string"
        );
    }

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

    Ok(())
}