Struct BackgroundTaskManager 

pub struct BackgroundTaskManager { /* private fields */ }

Manager for background tasks with disk persistence

Implementations

impl BackgroundTaskManager

pub async fn new(tasks_dir: &Path) -> Result<Self>

Create a new background task manager.

The tasks_dir is where task JSON files are persisted. If the directory doesn’t exist, it will be created. On creation, it loads any existing tasks from disk.

pub async fn from_config(config: &RuntimeConfig) -> Result<Self>

Create from runtime config — uses workdir/tasks/ as the tasks directory

pub async fn submit( &self, prompt: String, system_prompt: String, ) -> Result<String>

Submit a new background task and return its ID. The task is persisted immediately and will be executed in the background.

pub async fn execute( &self, task_id: &str, llm: Arc<dyn LLMProviderTrait>, ) -> Result<String>

Execute a background task with the given LLM client. Updates the task status to Running, runs the agent loop, and saves the result.

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

Get the current status of a task

pub async fn get_task(&self, task_id: &str) -> Result<BackgroundTask>

Get the full task details

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

List all tasks with their status

pub async fn cancel(&self, task_id: &str) -> Result<()>

Cancel a pending or running task

pub async fn resume_incomplete(&self) -> Vec<String>

Resume all incomplete tasks (Pending or Running) from disk. Returns the list of task IDs that need execution.

Trait Implementations

impl Clone for BackgroundTaskManager

fn clone(&self) -> BackgroundTaskManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackgroundTaskManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.