openai4s/execution/watchdog.py

• _never · function · L24-L25 — def _never() -> bool
• KernelNotResetTimeout · class · L28-L34 — class KernelNotResetTimeout(TimeoutError)
• KernelResetUnavailableTimeout · class · L37-L43 — class KernelResetUnavailableTimeout(TimeoutError)
• KernelCancellation · class · L46-L47 — class KernelCancellation(ExecutionCancelled)
• KernelNotResetCancellation · class · L50-L51 — class KernelNotResetCancellation(KernelCancellation)
• KernelResetUnavailableCancellation · class · L54-L55 — class KernelResetUnavailableCancellation(KernelCancellation)
• WatchdogPolicy · class · L59-L90 — class WatchdogPolicy
• from_environment · method · L68-L86 — def from_environment( cls, environ: Mapping[str, str] | None = None, *, poll_s: float = 1.0, interrupt_grace_s: float = 10.0, kill_grace_s: float = 10.0, ) -> "WatchdogPolicy"
• enabled · method · L89-L90 — def enabled(self) -> bool
• execute_with_watchdog · function · L93-L246 — def execute_with_watchdog( supervisor: KernelSupervisor, lease: KernelLease, run: Callable[[Any], T], *, policy: WatchdogPolicy, cancelled: Flag = _never, paused: Flag = _never, after_restart: Callable[[Any], None] | None = None, thread_name: str | None = None, ) -> T
• invoke · function · L118-L122 — def invoke() -> None
• _completed · function · L249-L252 — def _completed(box: dict[str, Any]) -> Any
• _flag · function · L255-L259 — def _flag(probe: Flag) -> bool