Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Centralized task lifecycle manager

Implementations

impl TaskManager

pub fn new() -> Self

Create a new task manager

pub fn spawn(&self, task: Task) -> TaskId

Spawn a new task

Returns the task ID.

pub fn start(&self, task_id: TaskId) -> Result<(), TaskManagerError>

Start executing a task

pub fn progress( &self, task_id: TaskId, message: impl Into<String>, ) -> Result<(), TaskManagerError>

Update task progress

pub fn complete( &self, task_id: TaskId, output: Option<Value>, ) -> Result<(), TaskManagerError>

Complete a task with result

pub fn fail( &self, task_id: TaskId, error: impl Into<String>, ) -> Result<(), TaskManagerError>

Fail a task with error

pub fn kill(&self, task_id: TaskId) -> Result<(), TaskManagerError>

Kill a task

pub fn get(&self, task_id: TaskId) -> Option<Task>

Get task by ID

pub fn get_result(&self, task_id: TaskId) -> Option<TaskResult>

Get task result

pub fn is_terminal(&self, task_id: TaskId) -> bool

Check if task is terminal

pub fn subscribe(&self, task_id: TaskId) -> Option<Receiver<TaskEvent>>

Subscribe to task events

Returns a receiver that will receive all events for the task. The receiver is closed when the task completes.

pub fn subscribe_all(&self) -> Receiver<TaskEvent>

Subscribe to all task events (global)

pub async fn wait( &self, task_id: TaskId, ) -> Result<TaskResult, TaskManagerError>

Wait for a task to complete

Returns the task result when the task completes.

pub fn add_child( &self, parent_id: TaskId, child_id: TaskId, ) -> Result<(), TaskManagerError>

Add a child task to a parent

pub fn spawn_child( &self, parent_id: TaskId, task: Task, ) -> Result<TaskId, TaskManagerError>

Spawn a child task with the given parent ID, setting up parent-child relationship.

This is a convenience method that combines spawn + add_child in one call.

pub async fn wait_children( &self, parent_id: TaskId, ) -> Result<Vec<TaskResult>, TaskManagerError>

Wait for all child tasks of a parent to complete.

Returns a list of results for each child task.

pub fn get_children( &self, parent_id: TaskId, ) -> Result<Vec<TaskId>, TaskManagerError>

Get all child task IDs for a parent task.

pub fn all_children_complete(&self, parent_id: TaskId) -> bool

Check if all children of a parent task are complete.

pub fn pending_tasks(&self) -> Vec<TaskId>

Get pending task IDs (FIFO)

pub fn pop_pending(&self) -> Option<TaskId>

Pop the next pending task

pub fn shutdown(&self)

Shutdown the manager

pub fn all_tasks(&self) -> HashMap<TaskId, Task>

Get all tasks

Trait Implementations

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.