Struct TasksRepo 

pub struct TasksRepo<'a> { /* private fields */ }

Implementations

impl TasksRepo<'_>

pub fn create(&self, new: NewTask) -> Result<TaskRecord>

pub fn get(&self, id: &str) -> Result<Option<TaskRecord>>

pub fn list(&self, limit: usize) -> Result<Vec<TaskRecord>>

pub fn update_status( &self, id: &str, status: TaskStatus, final_report: Option<&str>, ) -> Result<()>

pub fn claim_next_queued(&self) -> Result<Option<TaskRecord>>

Atomically claim the next runnable queued task for the daemon scheduler: flip it to Running and return it, or None when the queue is empty.

Only daemon-owned tasks WITH a persisted prompt are claimable — metadata-only tasks (interactive CLI runs, external create_task callers) are never executed by the scheduler. Order: priority (high → normal → low), then FIFO by created_at (id as tiebreaker, since two enqueues can share a coarse-clock timestamp). The claim is a single UPDATE … RETURNING, so concurrent claimers can never run the same task twice.

pub fn add_event(&self, task_id: &str, kind: &str, message: &str) -> Result<()>

pub fn events(&self, task_id: &str) -> Result<Vec<TaskTimelineEvent>>