agentq 0.2.1

An embeddable job queue with idempotency keys, per-lane backpressure and bounded concurrency, for agent tool calls.
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
59
60
61
62
63

#[derive(Debug, Clone)]
pub struct StepDef {
    pub name: String,
    pub retry_policy: RetryPolicy,
    pub timeout: Option<std::time::Duration>,
}

#[derive(Debug, Clone)]
pub enum StepStatus {
    Pending,
    Leased {
        worker_id: String,
        expires_at: std::time::SystemTime,
    },
    Completed {
        output: String,
    },
    Failed {
        reason: String,
        attempt: u32,
    },
    Waiting {
        reason: String,
    },
}

#[derive(Debug, Clone)]
pub struct RetryPolicy {
    pub max_attempts: u32,
    pub backoff: Backoff,
}

#[derive(Debug, Clone)]
pub enum Backoff {
    Fixed(std::time::Duration),
    Exponential {
        base: std::time::Duration,
        max: std::time::Duration,
    },
}

#[derive(Debug, Clone)]
pub struct Workflow {
    pub id: String,
    pub steps: Vec<StepDef>,
}

#[derive(Debug, Clone)]
pub struct Execution {
    pub workflow_id: String,
    pub step_index: usize,
    pub attempt: u32,
    pub worker_id: String,
    pub lease_expires_at: std::time::SystemTime,
}

/// A step's body. `Fn`, not `FnOnce` like `Job`'s `Func` — the engine may
/// call this again across retry attempts, so it can't be consumed on first run.
pub type StepFunc = Box<
    dyn Fn() -> std::pin::Pin<Box<dyn std::future::Future<Output = crate::JobResult> + Send>>
        + Send
        + Sync,
>;