Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Task manager for persisting and managing tasks

Implementations

impl TaskManager

pub fn new(base_dir: impl Into<PathBuf>) -> Self

Create a new task manager with the given base directory

pub fn load_task_list(&self, session_id: &str) -> Result<TaskList, TaskError>

Load the full task list for a session.

This returns the persisted state (or an empty list if none exists yet). It is used by checkpoint/rewind to snapshot and restore task state.

pub fn replace_task_list(&self, task_list: TaskList) -> Result<(), TaskError>

Replace the persisted task list for a session.

This is primarily used by checkpoint/rewind to restore a previous task state.

pub fn set_current_task_id( &self, session_id: &str, task_id: Option<String>, ) -> Result<(), TaskError>

Set or clear the current task pointer for a session.

If task_id is Some, it must exist in the session’s task list.

pub fn get_current_task_id( &self, session_id: &str, ) -> Result<Option<String>, TaskError>

Get the current task pointer for a session.

pub fn create_task( &self, session_id: &str, name: impl Into<String>, description: impl Into<String>, parent_id: Option<String>, ) -> Result<Task, TaskError>

Create a new task

pub fn update_task_status( &self, session_id: &str, task_id: &str, status: TaskStatus, ) -> Result<(), TaskError>

Update a task’s status

pub fn update_task( &self, session_id: &str, task_id: &str, name: Option<String>, description: Option<String>, ) -> Result<(), TaskError>

Update a task’s name and description

pub fn delete_task( &self, session_id: &str, task_id: &str, ) -> Result<Task, TaskError>

Delete a task

pub fn list_tasks(&self, session_id: &str) -> Result<Vec<Task>, TaskError>

List all tasks for a session

pub fn get_hierarchy( &self, session_id: &str, ) -> Result<Vec<(Task, Vec<Task>)>, TaskError>

Get task hierarchy for a session

pub fn list_descendants( &self, session_id: &str, task_id: &str, ) -> Result<Vec<Task>, TaskError>

List all descendant tasks for the given task.

pub fn get_task_tree( &self, session_id: &str, ) -> Result<Vec<TaskTreeNode>, TaskError>

Get a full recursive task tree for a session.

pub fn add_task_dependency( &self, session_id: &str, task_id: &str, blocked_by_id: &str, ) -> Result<(), TaskError>

Add a dependency relationship to a task.

pub fn set_task_background_job( &self, session_id: &str, task_id: &str, job: Option<TaskBackgroundJob>, ) -> Result<(), TaskError>

Update background job state for a task.

pub fn create_agent_task( &self, session_id: &str, name: impl Into<String>, description: impl Into<String>, agent_id: Option<String>, parent_id: Option<String>, ) -> Result<Task, TaskError>

Create a task from an agent (during LLM processing)

pub fn create_orchestrator_task( &self, session_id: &str, orchestrator_task_id: impl Into<String>, agent_id: impl Into<String>, name: impl Into<String>, description: impl Into<String>, context: Option<Value>, ) -> Result<Task, TaskError>

Create a task from an orchestrator delegated task

pub fn find_by_orchestrator_id( &self, session_id: &str, orchestrator_task_id: &str, ) -> Result<Option<Task>, TaskError>

Find a task by its orchestrator_task_id

pub fn update_task_metadata( &self, session_id: &str, task_id: &str, metadata: Value, ) -> Result<(), TaskError>

Update a task’s metadata

pub fn materialize_requirement_breakdown( &self, session_id: &str, specs: &[RequirementBreakdownTaskSpec], ) -> Result<MaterializedTaskBreakdown, TaskError>

Materialize a requirement breakdown into persisted agent-created tasks.

pub fn materialize_requirement_breakdown_under_parent( &self, session_id: &str, parent_task_id: &str, specs: &[RequirementBreakdownTaskSpec], ) -> Result<MaterializedTaskBreakdown, TaskError>

Materialize a requirement breakdown beneath an existing tracked root task.

pub fn initialize_auto_tracked_execution_plan( &self, session_id: &str, root_task_name: &str, original_input: &str, specs: &[RequirementBreakdownTaskSpec], ) -> Result<AutoTrackedExecutionPlan, TaskError>

Create a tracked root task and materialize a shared execution plan under it.

pub fn cancel_open_descendants( &self, session_id: &str, task_id: &str, ) -> Result<Vec<String>, TaskError>

Cancel any descendant tasks that are still open.

pub fn record_task_result( &self, session_id: &str, task_id: &str, success: bool, output: String, tool_calls: i32, duration_ms: i32, ) -> Result<TaskStatus, TaskError>

Record the result metadata for a task and update its status.

pub fn finalize_tracked_task_after_agent_run( &self, session_id: &str, task_id: &str, ) -> Result<TrackedTaskFinalization, TaskError>

Reconcile a tracked task after an agent run by examining descendant state.

pub fn record_memory_event( &self, session_id: &str, task_id: &str, event: TaskMemoryEvent, ) -> Result<(), TaskError>

Record a structured memory lifecycle event in task metadata.

pub fn get_memory_lifecycle( &self, session_id: &str, task_id: &str, ) -> Result<Option<TaskMemoryLifecycle>, TaskError>

Read structured memory lifecycle data from task metadata.

pub fn update_execution_state<F>( &self, session_id: &str, task_id: &str, update: F, ) -> Result<TaskExecutionState, TaskError>

where F: FnOnce(&mut TaskExecutionState),

Update the runtime execution state stored in task metadata.

pub fn get_execution_state( &self, session_id: &str, task_id: &str, ) -> Result<Option<TaskExecutionState>, TaskError>

Read runtime execution state from task metadata.

pub fn get_task( &self, session_id: &str, task_id: &str, ) -> Result<Option<Task>, TaskError>

Get a specific task by ID