basis-tasks 0.16.2

The durable task layer over basis: a filesystem-coordinated lifecycle for spawned agents, reachable from Rust and not only from the CLI.
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

//! A full workspace is refused as one, so a host can tell its callers so
//! rather than report its own failure.

use std::{path::Path, time::Duration};

use basis_tasks::{Approve, MAX_TASKS, RunSpec, Tasks};

fn spec() -> RunSpec {
    RunSpec::new("hello")
        .with_approve(Approve::Always)
        .with_deadline(Duration::from_secs(60))
        .detached()
}

/// The directory a task's own directory sits in.
fn agents_dir(root: &Path, id: &str) -> Option<std::path::PathBuf> {
    for entry in std::fs::read_dir(root).ok()? {
        let path = entry.ok()?.path();
        if path.file_name().is_some_and(|name| name == id) {
            return path.parent().map(Path::to_path_buf);
        }
        if path.is_dir()
            && let Some(found) = agents_dir(&path, id)
        {
            return Some(found);
        }
    }
    None
}

#[test]
fn a_full_workspace_is_refused_as_a_task_limit() {
    let data = tempfile::tempdir().expect("tempdir");
    let workspace = tempfile::tempdir().expect("tempdir");
    let tasks = Tasks::open_at(data.path(), workspace.path()).expect("opens");
    let first = tasks.spawn(spec()).expect("spawns");
    let id = first.as_str().rsplit_once('/').unwrap().1;
    let agents = agents_dir(data.path(), id).expect("the task has a directory");
    for filler in 1..MAX_TASKS {
        std::fs::create_dir(agents.join(format!("filler-{filler}"))).unwrap();
    }

    let refused = tasks.spawn(spec()).expect_err("the workspace is full");
    assert!(refused.is_task_limit(), "{refused}");
    let other = tasks
        .spawn(RunSpec::new("  "))
        .expect_err("an empty prompt is refused");
    assert!(!other.is_task_limit());
}