Struct AsyncSqliteTaskRepository 

pub struct AsyncSqliteTaskRepository { /* private fields */ }

Async wrapper around SqliteTaskRepository built on AsyncDatabase.

Implementations

impl AsyncSqliteTaskRepository

pub fn new(async_db: Arc<AsyncDatabase>) -> Self

Creates a new async repository wrapper.

pub async fn resolve_task_id(&self, prefix: &str) -> Result<String>

Resolves a full task identifier from an ID prefix.

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

Loads a summary row for a task.

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

Loads the full detail bundle for a task.

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

Loads (total, resolved, unresolved) item counts for a task.

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

Lists task identifiers ordered by creation time descending.

pub async fn find_latest_resumable_task_id( &self, include_pending: bool, ) -> Result<Option<String>>

Returns the latest resumable task, optionally including pending tasks.

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

Loads execution state required to resume a task.

pub async fn first_task_item_id(&self, task_id: &str) -> Result<Option<String>>

Returns the first task-item identifier for a task, if present.

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

Counts unresolved task items.

pub async fn list_task_items_for_cycle( &self, task_id: &str, ) -> Result<Vec<TaskItemRow>>

Lists task items participating in the current cycle.

pub async fn load_task_status(&self, task_id: &str) -> Result<Option<String>>

Loads the current task status string.

pub async fn load_task_name(&self, task_id: &str) -> Result<Option<String>>

Loads the human-readable task name.

pub async fn list_task_log_runs( &self, task_id: &str, limit: usize, ) -> Result<Vec<TaskLogRunRow>>

Lists recent command runs used for log inspection.

pub async fn load_task_graph_debug_bundles( &self, task_id: &str, ) -> Result<Vec<TaskGraphDebugBundle>>

Loads graph-planning debug bundles for a task.

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

Updates a task status and optionally marks completion.

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

Resets unresolved items back to pending without changing the task status. Called before enqueuing a task so the worker can re-process them.

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

Resets a task into a fresh batch-start state.

pub async fn update_task_cycle_state( &self, task_id: &str, current_cycle: u32, init_done: bool, ) -> Result<()>

Persists cycle counters and init_once state.

pub async fn mark_task_item_running(&self, task_item_id: &str) -> Result<()>

Marks a task item as running.

pub async fn set_task_item_terminal_status( &self, task_item_id: &str, status: &str, ) -> Result<()>

Sets a terminal status for a task item.

pub async fn update_task_item_status( &self, task_item_id: &str, status: &str, ) -> Result<()>

Updates a task item to an arbitrary status.

pub async fn update_task_item_pipeline_vars( &self, task_item_id: &str, pipeline_vars_json: &str, ) -> Result<()>

Persists accumulated pipeline variables back to the task item’s dynamic_vars column.

pub async fn delete_task_and_collect_log_paths( &self, task_id: &str, ) -> Result<Vec<String>>

Deletes a task and returns log paths that should be removed.

pub async fn insert_command_run(&self, run: NewCommandRun) -> Result<()>

Inserts a command-run record.

pub async fn insert_event(&self, event: DbEventRecord) -> Result<()>

Inserts an event record.

pub async fn update_command_run(&self, run: NewCommandRun) -> Result<()>

Updates an existing command-run record.

pub async fn update_command_run_with_events( &self, run: NewCommandRun, events: Vec<DbEventRecord>, ) -> Result<()>

Updates a command run and appends emitted events.

pub async fn persist_phase_result_with_events( &self, run: NewCommandRun, events: Vec<DbEventRecord>, ) -> Result<()>

Persists a completed phase result together with emitted events.

pub async fn update_command_run_pid(&self, run_id: &str, pid: i64) -> Result<()>

Updates the PID associated with a running command.

pub async fn find_active_child_pids(&self, task_id: &str) -> Result<Vec<i64>>

Returns active child PIDs for a task.

pub async fn find_inflight_command_runs_for_task( &self, task_id: &str, ) -> Result<Vec<InflightRunRecord>>

Returns in-flight command runs for a task (FR-038).

pub async fn find_completed_runs_for_pending_items( &self, task_id: &str, ) -> Result<Vec<CompletedRunRecord>>

Returns completed runs whose parent items are still pending (FR-038).

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

Counts stale pending items (FR-038).

pub async fn count_recent_heartbeats_for_items( &self, task_id: &str, item_ids: &[String], cutoff_ts: &str, ) -> Result<i64>

FR-052: Counts recent heartbeat events for specified item IDs since cutoff.

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

Persists the serialized pipeline-variable map for a task.

pub async fn update_task_item_tickets( &self, task_item_id: &str, ticket_files_json: &str, ticket_content_json: &str, ) -> Result<()>

Persists active ticket paths and preview content for a task item.

pub async fn insert_task_graph_run(&self, run: NewTaskGraphRun) -> Result<()>

Inserts a task-graph planning run.

pub async fn update_task_graph_run_status( &self, graph_run_id: &str, status: &str, ) -> Result<()>

Updates the status of a task-graph planning run.

pub async fn pause_all_running_tasks_and_items(&self) -> Result<usize>

Blanket-pause all running tasks and reset their items to pending. Used during daemon shutdown before exec() to prevent orphaned state.

pub async fn pause_restart_pending_tasks_and_items(&self) -> Result<usize>

Pauses only tasks in restart_pending status and resets their running items.

pub async fn recover_orphaned_running_items( &self, ) -> Result<Vec<(String, Vec<String>)>>

Recovers all orphaned running items across all tasks.

pub async fn recover_orphaned_running_items_for_task( &self, task_id: &str, ) -> Result<Vec<String>>

Recovers orphaned running items for a single task.

pub async fn recover_stalled_running_items( &self, stall_threshold_secs: u64, exclude_task_ids: HashSet<String>, ) -> Result<Vec<(String, Vec<String>)>>

Recovers stalled running items older than the given threshold.

Tasks in exclude_task_ids are skipped (they have active workers).

pub async fn insert_task_graph_snapshot( &self, snapshot: NewTaskGraphSnapshot, ) -> Result<()>

Persists one task-graph snapshot payload.