Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Task manager

Manages the lifecycle of async tasks, including creation, status polling, progress updates, and result retrieval.

Implementations

impl TaskManager

pub fn new() -> Self

Create a new task manager

pub fn with_base_uri(base_uri: impl Into<String>) -> Self

Create a new task manager with a custom base URI

pub async fn create_task(&self, request: TaskRequest) -> Result<TaskHandle>

Create a new task

Returns a task handle immediately with the task in Queued state.

pub async fn get_task_status(&self, task_id: &TaskId) -> Result<TaskStatus>

Get task status

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

Get task result

Returns an error if the task hasn’t completed yet.

pub async fn update_progress( &self, task_id: &TaskId, progress: TaskProgress, ) -> Result<()>

Update task progress

This should be called by the worker executing the task.

pub async fn mark_working(&self, task_id: &TaskId) -> Result<()>

Mark task as working

pub async fn mark_completed( &self, task_id: &TaskId, result: Value, ) -> Result<()>

Mark task as completed with result

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

Mark task as failed

pub async fn mark_cancelled(&self, task_id: &TaskId) -> Result<()>

Mark task as cancelled

pub async fn mark_input_required(&self, task_id: &TaskId) -> Result<()>

Mark task as requiring input

pub async fn list_tasks(&self) -> Result<Vec<TaskStatus>>

List all tasks

pub async fn cancel_task(&self, task_id: &TaskId) -> Result<()>

Cancel a task

Returns an error if the task is already in a terminal state or doesn’t support cancellation.

pub async fn cleanup_old_tasks(&self, older_than: Duration) -> Result<usize>

Clean up old completed tasks

Removes tasks that completed before the given threshold.

Trait Implementations

impl Clone for TaskManager

fn clone(&self) -> TaskManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.