bamboo-engine 2026.4.30

Execution engine and orchestration for the Bamboo agent framework
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

use bamboo_domain::{TaskItem, TaskItemStatus, TaskList};

use super::{TaskLoopContext, TaskLoopItem};

impl TaskLoopContext {
    /// Create `TaskLoopContext` from the session's task list.
    pub fn from_session(session: &bamboo_agent_core::Session) -> Option<Self> {
        session.task_list.as_ref().map(|task_list| {
            // Preserve version from existing task_list metadata if available.
            // This prevents version reset across multiple executions.
            let existing_version = session
                .metadata
                .get("task_list_version")
                .or_else(|| session.metadata.get("todo_list_version"))
                .and_then(|v| v.parse::<u64>().ok())
                .unwrap_or(0);

            let items: Vec<TaskLoopItem> = task_list
                .items
                .iter()
                .map(|item| TaskLoopItem {
                    id: item.id.clone(),
                    description: item.description.clone(),
                    status: item.status.clone(),
                    depends_on: item.depends_on.clone(),
                    notes: item.notes.clone(),
                    active_form: item.active_form.clone(),
                    parent_id: item.parent_id.clone(),
                    phase: item.phase.clone(),
                    priority: item.priority.clone(),
                    completion_criteria: item.completion_criteria.clone(),
                    evidence: item.evidence.clone(),
                    blockers: item.blockers.clone(),
                    transitions: item.transitions.clone(),
                    tool_calls: Vec::new(),
                    started_at_round: item
                        .transitions
                        .iter()
                        .find(|transition| {
                            matches!(transition.to_status, TaskItemStatus::InProgress)
                        })
                        .and_then(|transition| transition.round),
                    completed_at_round: item
                        .transitions
                        .iter()
                        .rev()
                        .find(|transition| {
                            matches!(transition.to_status, TaskItemStatus::Completed)
                        })
                        .and_then(|transition| transition.round),
                })
                .collect();

            Self {
                session_id: task_list.session_id.clone(),
                active_item_id: items
                    .iter()
                    .find(|item| matches!(item.status, TaskItemStatus::InProgress))
                    .map(|item| item.id.clone()),
                items,
                current_round: 0,
                max_rounds: 200,
                created_at: task_list.created_at,
                updated_at: task_list.updated_at,
                version: existing_version,
            }
        })
    }

    /// Convert back to `TaskList` for persistence.
    pub fn into_task_list(self) -> TaskList {
        TaskList {
            session_id: self.session_id,
            title: "Agent Tasks".to_string(),
            items: self
                .items
                .into_iter()
                .map(|loop_item| TaskItem {
                    id: loop_item.id,
                    description: loop_item.description,
                    status: loop_item.status,
                    depends_on: loop_item.depends_on,
                    notes: loop_item.notes,
                    active_form: loop_item.active_form,
                    parent_id: loop_item.parent_id,
                    phase: loop_item.phase,
                    priority: loop_item.priority,
                    completion_criteria: loop_item.completion_criteria,
                    evidence: loop_item.evidence,
                    blockers: loop_item.blockers,
                    transitions: loop_item.transitions,
                })
                .collect(),
            created_at: self.created_at,
            updated_at: self.updated_at,
        }
    }
}