openai4s/orchestration/reclaimer.py

• SweepReport · class · L48-L58 — class SweepReport
• post_init · method · L56-L58 — def post_init(self) -> None
• LeaseReclaimer · class · L61-L180 — class LeaseReclaimer
• init · method · L64-L82 — def init( self, *, leases: Any, workloads: Any, clock_ms: Callable[[], int] = lambda: int(time.time() * 1000), sweep_s: float = DEFAULT_SWEEP_S, on_event: Callable[[str, dict], None] | None = None, ) -> None
• running · method · L86-L91 — def running(self) -> bool
• start · method · L93-L101 — def start(self) -> None
• stop · method · L103-L111 — def stop(self, *, timeout_s: float = 5.0) -> None
• _run · method · L113-L129 — def _run(self) -> None
• sweep · method · L133-L174 — def sweep(self) -> SweepReport
• _emit · method · L176-L180 — def _emit(self, kind: str, payload: dict) -> None
• _store_is_gone · function · L183-L185 — def _store_is_gone(exc: BaseException) -> bool