ai-dispatch 11.2.0

Multi-AI CLI team orchestrator
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

// Regression coverage for descendant activity, first-output parity, and hung retry evidence.
// The fake server starts real silent child work without invoking a model.

use super::*;
#[path = "fixture.rs"]
mod fixture;
use fixture::Fixture;

fn policy(idle_ms: u64) -> crate::config::timeout_policy::TimeoutPolicy {
    let mut policy = crate::config::timeout_policy::TimeoutPolicy::default();
    policy.idle = Duration::from_millis(idle_ms);
    policy.first_token = Duration::from_millis(100);
    policy
}

#[test]
fn descendant_activity_only_extends_idle_after_first_output() {
    let old = SystemTime::now() - Duration::from_secs(5);
    assert!(!expired(
        old,
        Some(SystemTime::now()),
        true,
        Duration::from_secs(1)
    ));
    assert!(expired(
        old,
        Some(SystemTime::now()),
        false,
        Duration::from_secs(1)
    ));
}

#[test]
fn quiet_cpu_child_survives_the_notification_idle_limit() {
    let fixture = Fixture::new("busy");
    fixture.dispatch_with_policy(policy(500));
    assert_eq!(
        fixture
            .store
            .get_task(fixture.task.as_str())
            .unwrap()
            .unwrap()
            .status,
        TaskStatus::Done
    );
    assert!(
        monitor::hung_context(&fixture.store.get_events(fixture.task.as_str()).unwrap()).is_none()
    );
}

#[test]
fn silence_before_first_item_uses_piped_exec_idle_window() {
    let fixture = Fixture::new("first-output");
    fixture.dispatch_with_policy(policy(1500));
    assert_eq!(
        fixture
            .store
            .get_task(fixture.task.as_str())
            .unwrap()
            .unwrap()
            .status,
        TaskStatus::Done
    );
}

#[test]
fn idle_timeout_records_the_metadata_used_by_hung_auto_retry() {
    let fixture = Fixture::new("hung");
    fixture.dispatch_with_policy(policy(500));
    let events = fixture.store.get_events(fixture.task.as_str()).unwrap();
    let context =
        monitor::hung_context(&events).expect("eligible for the existing hung recovery path");
    assert!(!context.transient);
    assert!(context.event_count > 0);
    assert!(events.iter().any(|event| event.detail == "hung_detected"));
    assert_eq!(
        fixture
            .store
            .get_task(fixture.task.as_str())
            .unwrap()
            .unwrap()
            .status,
        TaskStatus::Failed
    );
}