uniqc.gateway.db.archive_store module

Archive store — moves tasks in/out of the archived_tasks table.

The archive lives in the same tasks.sqlite file as the main task store. This module provides an ArchiveStore class that mirrors TaskStore’s interface but operates on the archived_tasks table.

class uniqc.gateway.db.archive_store.ArchiveStore

Bases: object

Persistent archive for completed / failed tasks.

Tasks are moved atomically from tasks → archived_tasks so that the hot-path query on tasks stays fast even when many historical tasks have accumulated.

archive_task(task_id)

Move a task from tasks to archived_tasks.

Cascades shards to archived_task_shards first; the task row’s ON DELETE CASCADE would otherwise wipe them silently.

Returns True if the task existed and was moved.

count_archived(*, status=None, backend=None)

Return total number of archived tasks.

delete_archived(task_id)

Permanently remove an archived task. Returns True if it existed.

get_archived(task_id)

Return an archived task by id, or None.

list_archived(*, status=None, backend=None, limit=None, offset=None)

List archived tasks, newest-first by submit_time.

restore_task(task_id)

Move a task from archived_tasks back to tasks.

Cascades archived shards back to task_shards. Returns True if the task existed and was restored.