Ingestion offsets: where each script task left off, in AUD_TASK_OFFSET_TRACKER.
StoredOffset
dataclass
An offset as stored: its type (NUMBER, TEXT or TIMESTAMP) and its text.
fetch_task_offset
fetch_task_offset(conn: Connection, task_id: int) -> StoredOffset | None
Return the offset task_id stored, or None before its first successful run.
save_task_offset
save_task_offset(conn: Connection, task_id: int, offset: StoredOffset) -> None
Store offset as where task_id left off.