openai4s/server/recovery_runtime.py

• PythonRuntimeSpec · class · L32-L38 — class PythonRuntimeSpec
• RecoveryRuntimePorts · class · L42-L58 — class RecoveryRuntimePorts
• _RecoveryKernelCandidate · class · L61-L92 — class _RecoveryKernelCandidate
• init · method · L64-L80 — def init( self, *, language: str, key: Any, factory: Callable[[], Kernel], manifest: BootstrapManifest, ) -> None
• shutdown · method · L82-L84 — def shutdown(self) -> None
• interrupt · method · L86-L92 — def interrupt(self) -> bool: # Forward the kernel's verdict instead of asserting one. True here # meant "we called interrupt", and the caller reads it as "the cell was # stopped" -- the same gap Kernel.interrupt now closes underneath. # None is a kernel double making no claim and keeps the old answer.
• SessionRecoveryRuntime · class · L95-L440 — class SessionRecoveryRuntime
• init · method · L98-L106 — def init( self, ports: RecoveryRuntimePorts, *, read_isolation: KernelReadIsolation | None = None, ) -> None
• fresh_manifests · method · L108-L126 — def fresh_manifests(self) -> tuple[BootstrapManifest, ...]
• run · method · L128-L261 — def run(self, plan: RecoveryActionPlan) -> dict[str, Any]
• hydrate_workspace · function · L143-L164 — def hydrate_workspace(_candidate, payload: Mapping[str, Any]) -> None
• hydrate_artifact · function · L166-L197 — def hydrate_artifact(_candidate, payload: Mapping[str, Any]) -> None
• publish · function · L199-L233 — def publish(candidate, manifest, source_generation_id)
• kernel_status_event · method · L263-L279 — def kernel_status_event( self, result: Mapping[str, Any], recovery_id: str ) -> dict[str, Any]
• _build_candidate · method · L281-L331 — def _build_candidate(self, manifest: BootstrapManifest) -> _RecoveryKernelCandidate
• factory · function · L305-L306 — def factory() -> Kernel
• factory · function · L316-L321 — def factory() -> Kernel
• _bootstrap_candidate · method · L333-L379 — def _bootstrap_candidate( self, candidate: _RecoveryKernelCandidate, manifest: BootstrapManifest, ) -> None
• _execute_cell · method · L382-L385 — def _execute_cell(candidate, code: str, language: str)
• _inspect_symbols · method · L388-L409 — def _inspect_symbols(candidate, language: str)
• _artifact_digest · method · L411-L421 — def _artifact_digest(self, _candidate, name: str) -> str | None
• _artifact_live_path · method · L423-L440 — def _artifact_live_path(self, version: Mapping[str, Any]) -> Path | None
• _probe_python_environment · function · L443-L502 — def _probe_python_environment(kernel: Kernel, *, origin: str) -> dict[str, Any]
• _probe_r_environment · function · L505-L553 — def _probe_r_environment( kernel: Kernel, *, interpreter: str, origin: str ) -> dict[str, Any]
• bootstrap_r_generation · function · L556-L591 — def bootstrap_r_generation( kernels: KernelSupervisor, workspace: str | Path, lease: KernelLease, ) -> dict[str, Any]
• bootstrap_python_generation · function · L594-L666 — def bootstrap_python_generation( kernel: Kernel, workspace: str | Path, bootstrap_code: str, ) -> dict[str, Any]
• python_runtime_spec · function · L669-L683 — def python_runtime_spec(environment: Any) -> PythonRuntimeSpec
• _json_after_marker · function · L686-L693 — def _json_after_marker(output: str, marker: str) -> Any