Struct AgentTaskStore 

pub struct AgentTaskStore {
    pool: SqlitePool,
    workspace_id: String,
}

Fields

pool: SqlitePool

workspace_id: String

Implementations

impl AgentTaskStore

pub fn new(pool: SqlitePool, workspace_id: &str) -> Result<Self>

pub(crate) fn run_store(&self) -> Result<AgentRunStore>

pub async fn submit( &self, submission: AgentTaskSubmission, ) -> Result<AgentTaskSubmissionResult>

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

pub async fn inspect(&self, id: &str) -> Result<Option<AgentTaskInspection>>

Inspect scheduling state without copying execution state into the task.

pub async fn list_inspections( &self, limit: u32, ) -> Result<Vec<AgentTaskInspection>>

List bounded scheduling records with authoritative linked run projections.

pub async fn list(&self, limit: u32) -> Result<Vec<AgentTask>>

pub async fn events( &self, id: &str, after_sequence: i64, limit: u32, ) -> Result<Vec<AgentTaskEvent>>

pub async fn claim_next( &self, worker_id: &str, lease_seconds: u64, max_attempts: u32, ) -> Result<Option<AgentTaskClaim>>

Claim the oldest queued task using the database clock for its lease.

pub async fn claim_next_expired( &self, worker_id: &str, lease_seconds: u64, ) -> Result<Option<ExpiredAgentTaskClaim>>

Take scheduling ownership of the oldest expired claim for reconciliation.

pub async fn heartbeat( &self, claim: &AgentTaskClaim, lease_seconds: u64, ) -> Result<AgentTask>

Extend an owned claim from the database’s current time.

pub async fn link_run( &self, claim: &AgentTaskClaim, agent_version: &str, model: &str, budgets: RunBudgets, ) -> Result<AgentRun>

Atomically create the task’s sole root run and persist its immutable link.

pub async fn finish_identity_changed( &self, claim: &AgentTaskClaim, ) -> Result<AgentTask>

pub async fn finish_run_stopped( &self, claim: &AgentTaskClaim, ) -> Result<AgentTask>

pub async fn finish_cancelled_before_run( &self, claim: &AgentTaskClaim, ) -> Result<AgentTask>

pub async fn finish_claim_attempts_exhausted( &self, claim: &AgentTaskClaim, ) -> Result<AgentTask>

pub async fn finish_restart_required( &self, claim: &AgentTaskClaim, ) -> Result<AgentTask>

pub async fn finish_reconciliation_required( &self, claim: &AgentTaskClaim, ) -> Result<AgentTask>

pub async fn requeue(&self, claim: &AgentTaskClaim) -> Result<AgentTask>

Return an expired pre-run claim to the queue without changing attempts.

pub(crate) async fn fail_linked_run_setup( &self, claim: &AgentTaskClaim, run_id: &str, ) -> Result<AgentTask>

async fn finish_claim( &self, claim: &AgentTaskClaim, reason: &str, require_run: bool, ) -> Result<AgentTask>

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

Request cancellation without rewriting linked run state.

pub async fn cancel_queued(&self, id: &str) -> Result<AgentTask>

Backward-compatible queued-only cancellation surface.

Trait Implementations

impl Clone for AgentTaskStore

fn clone(&self) -> AgentTaskStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.