openai4s/storage/recovery.py

• RecoveryJournalRepository · class · L37-L166 — class RecoveryJournalRepository
• init · method · L38-L50 — def init( self, connection: sqlite3.Connection, lock: Any, *, clock_ms: Callable[[], int], ) -> None
• append · method · L52-L118 — def append( self, *, recovery_id: str, root_frame_id: str, branch_id: str | None, phase: str, status: str, detail: Any = None, source_generation_id: str | None = None, candidate_generation_id: str | None = None, sequence: int | None = None, entry_id: str | None = None, created_at: int | None = None, ) -> dict[str, Any]
• list · method · L120-L151 — def list( self, *, recovery_id: str | None = None, root_frame_id: str | None = None, branch_id: str | None = None, limit: int = 1000, newest: bool = False, ) -> list[dict[str, Any]]
• _text · method · L154-L157 — def _text(name: str, value: str) -> str
• _decode · method · L160-L166 — def _decode(row: sqlite3.Row) -> dict[str, Any]