openai4s/server/recovery_execution.py

• _not_cancelled · function · L25-L26 — def _not_cancelled() -> bool
• _ignore_candidate · function · L29-L30 — def _ignore_candidate(_candidate: Candidate) -> None
• _ignore_event · function · L33-L34 — def _ignore_event(_event: dict[str, Any]) -> None
• RecoveryExecutionPorts · class · L38-L51 — class RecoveryExecutionPorts
• RecoveryMutationExecutor · class · L54-L174 — class RecoveryMutationExecutor
• init · method · L57-L63 — def init( self, control: RecoveryControlService, ports: RecoveryExecutionPorts, ) -> None
• run · method · L65-L174 — def run(self, plan: RecoveryActionPlan) -> dict[str, Any]
• build · function · L70-L74 — def build(value: BootstrapManifest) -> Candidate
• _recipe_for_language · function · L177-L211 — def _recipe_for_language( recipe: RecoveryRecipe, language: str, *, include_hydration: bool, ) -> RecoveryRecipe
• _aggregate_status · function · L214-L228 — def _aggregate_status(results: list[RecoveryResult], expected: int) -> str