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

// Verification regressions for remote lock queue time versus command execution time.
// Keeps task deadlines absolute while excluding lock waits from duration budgets.
// Deps: verify runner, temporary executable and subprocess permit.

use super::*;
use chrono::Local;

fn lock_wait_command(dir: &Path) {
    let script = dir.join("verify");
    crate::support::test_env::write_executable(
        &script,
        concat!(
            "#!/bin/sh\n",
            "echo 'rbox: waiting for lock (timeout 10 s); holder test' >&2\n",
            "sleep 1\n",
            "echo 'rbox: job test-job' >&2\n",
            "sleep 0.1\n",
            "echo verified\n",
        ),
    );
}

#[test]
fn verify_lock_queue_time_does_not_consume_verify_timeout() {
    let _permit = crate::support::test_subprocess::acquire();
    let dir = tempfile::tempdir().expect("temp");
    lock_wait_command(dir.path());
    let result = run_verify_with_timeout(
        dir.path(),
        Some("./verify"),
        None,
        None,
        Duration::from_millis(400),
    )
    .expect("verify");
    assert!(result.success, "{result:?}");
    assert!(!result.timed_out);
    assert!(result.output.contains("verified"));
}

#[test]
fn verify_lock_queue_still_obeys_task_deadline() {
    let _permit = crate::support::test_subprocess::acquire();
    let dir = tempfile::tempdir().expect("temp");
    lock_wait_command(dir.path());
    let result = run_verify_with_env(
        dir.path(),
        Some("./verify"),
        None,
        None,
        VerifyBudget::Deadline(Local::now() + chrono::Duration::milliseconds(400)),
        &[],
    )
    .expect("verify");
    assert!(result.timed_out);
    assert!(!result.output.contains("verified"));
}