openai4s/storage/kernels.py

• KernelGenerationDTO · class · L60-L78 — class KernelGenerationDTO(TypedDict)
• _required_text · function · L84-L87 — def _required_text(name: str, value: str) -> str
• _state · function · L90-L94 — def _state(value: str) -> str
• _uuid_text · function · L97-L102 — def _uuid_text(name: str, value: str | None = None) -> str
• _canonical_json · function · L105-L113 — def _canonical_json(value: Any) -> str | None
• _json_load · function · L116-L122 — def _json_load(value: str | None) -> Any
• _manifest_id · function · L125-L129 — def _manifest_id(prefix: str, payload: str | None) -> str | None
• KernelGenerationRepository · class · L132-L428 — class KernelGenerationRepository
• init · method · L135-L147 — def init( self, connection: sqlite3.Connection, lock: Any, *, clock_ms: Callable[[], int], ) -> None
• create · method · L149-L218 — def create( self, *, root_frame_id: str, language: str, branch_id: str | None = None, generation_id: str | None = None, parent_generation_id: str | None = None, environment: Any = None, bootstrap: Any = None, worker_pid: int | None = None, owner_instance_id: str | None = None, state: str = "active", recovered_from_generation_id: str | None = None, started_at: int | None = None, ) -> KernelGenerationDTO
• touch · method · L220-L258 — def touch( self, generation_id: str, *, state: str | None = None, worker_pid: int | None | object = _UNSET, bootstrap: Any = _UNSET, at: int | None = None, ) -> KernelGenerationDTO
• compare_and_swap_bootstrap · method · L260-L305 — def compare_and_swap_bootstrap( self, generation_id: str, *, expected_manifest_id: str | None, bootstrap: Any, at: int | None = None, ) -> KernelGenerationDTO | None
• finish · method · L307-L332 — def finish( self, generation_id: str, *, state: str, reason: str, ended_at: int | None = None, ) -> KernelGenerationDTO
• abandon_live · method · L334-L363 — def abandon_live( self, *, owner_instance_id: str, reason: str = "daemon_restart", ended_at: int | None = None, ) -> int
• get · method · L365-L371 — def get(self, generation_id: str) -> KernelGenerationDTO | None
• latest · method · L373-L387 — def latest( self, root_frame_id: str, language: str, *, branch_id: str | None = None, ) -> KernelGenerationDTO | None
• list · method · L389-L411 — def list( self, root_frame_id: str, *, language: str | None = None, branch_id: str | None = None, ) -> list[KernelGenerationDTO]
• _row_locked · method · L413-L420 — def _row_locked(self, generation_id: str) -> sqlite3.Row
• _normalize · method · L423-L428 — def _normalize(row: sqlite3.Row) -> KernelGenerationDTO