← Về thư mục
openai4s/server/recovery_control.py
- RecoveryActionError · class · L34-L35 — class RecoveryActionError(RuntimeError)
- RecoveryActionPlan · class · L39-L47 — class RecoveryActionPlan
- RecoveryStore · class · L50-L63 — class RecoveryStore(Protocol)
- append_recovery_event · method · L51-L51 — def append_recovery_event(self, **fields: Any) -> dict
- list_recovery_events · method · L53-L53 — def list_recovery_events(self, **filters: Any) -> list[dict]
- get_session_branch · method · L55-L55 — def get_session_branch(self, branch_id: str) -> dict | None
- get_session_checkpoint · method · L57-L57 — def get_session_checkpoint(self, checkpoint_id: str) -> dict | None
- get_setting · method · L59-L59 — def get_setting(self, key: str, default: str | None = None) -> str | None
- latest_kernel_generation · method · L61-L63 — def latest_kernel_generation( self, root_frame_id: str, language: str, *, branch_id: str | None = None ) -> dict | None
- RecoveryControlService · class · L66-L484 — class RecoveryControlService
- init · method · L69-L82 — def init( self, store: RecoveryStore, *, workspace_tree_exists: Callable[[str], bool] | None = None, event_sink: Callable[[dict[str, Any]], None] | None = None, payload_chars: int = 20_000, ) -> None
- record · method · L84-L136 — def record(self, event: Mapping[str, Any]) -> dict
- pipeline · method · L138-L143 — def pipeline(self, **ports: Any) -> KernelRecoveryOrchestrator
- status · method · L145-L235 — def status( self, root_frame_id: str, *, branch_id: str | None = None, recovery_id: str | None = None, limit: int = 1000, ) -> dict[str, Any]
- actions · method · L237-L341 — def actions( self, root_frame_id: str, *, branch_id: str | None = None, ) -> dict[str, Any]
- prepare_action · method · L343-L453 — def prepare_action( self, root_frame_id: str, action_id: str, *, branch_id: str | None = None, confirmed: bool = False, fresh_manifests: tuple[BootstrapManifest, ...] = (), ) -> RecoveryActionPlan
- _attempt · method · L455-L484 — def _attempt(self, rows: list[dict]) -> dict[str, Any]
- _journal_state · function · L487-L513 — def _journal_state(rows: list[dict]) -> str
- _generation_state · function · L516-L528 — def _generation_state(generations) -> str
- _public_generation · function · L531-L548 — def _public_generation(value: Mapping[str, Any] | None) -> dict | None
- _restorable · function · L551-L576 — def _restorable(checkpoint: Mapping[str, Any] | None) -> tuple[bool, str | None]
- _parse_recipe · function · L579-L643 — def _parse_recipe(value: Any, *, cell_cursor: int = 0) -> RecoveryRecipe
- _action · function · L646-L660 — def _action( action_id: str, enabled: bool, reason: str | None, *, requires_ticket: bool = False, requires_confirmation: bool = False, ) -> dict[str, Any]
- _bounded_public · function · L663-L679 — def _bounded_public(value: Any, limit: int) -> Any
- _redact · function · L682-L703 — def _redact(value: Any) -> Any
- _required · function · L706-L709 — def _required(name: str, value: str) -> str