openai4s/storage/delegation.py

• DelegationProjectionRepository · class · L93-L764 — class DelegationProjectionRepository
• init · method · L96-L111 — def init( self, connection: sqlite3.Connection, lock: Any, *, clock_ms: Callable[[], int], ) -> None
• restore · method · L113-L198 — def restore( self, *, root_frame_id: str, owner_instance_id: str, runner_instance_id: str, budget_limit: int, ) -> dict[str, Any]
• reserve · method · L200-L321 — def reserve( self, *, root_frame_id: str, owner_instance_id: str, runner_instance_id: str, count: int, depth: int, parent_child_id: str | None, parent_action_group_id: str | None = None, native_call_id: str | None = None, request_sha256: str | None = None, payload: Mapping[str, Any] | None = None, ) -> dict[str, Any]
• continue_request · method · L323-L407 — def continue_request( self, *, root_frame_id: str, owner_instance_id: str, runner_instance_id: str, child_id: str, depth: int, parent_child_id: str | None, ) -> dict[str, Any]
• request_for_child · method · L409-L421 — def request_for_child( self, *, root_frame_id: str, child_id: str ) -> dict[str, Any] | None
• _reuse_request_locked · method · L423-L460 — def _reuse_request_locked( self, root: str, *, parent_action_group_id: str, native_call_id: str, request_sha256: str, ) -> dict[str, Any] | None
• release · method · L462-L489 — def release( self, *, root_frame_id: str, owner_instance_id: str, runner_instance_id: str, count: int = 1, ) -> dict[str, Any]
• persist_child · method · L491-L567 — def persist_child( self, *, root_frame_id: str, owner_instance_id: str, runner_instance_id: str, child: Mapping[str, Any], messages: Sequence[Mapping[str, Any]] = (), ) -> dict[str, Any] | None
• project · method · L569-L572 — def project(self, root_frame_id: str) -> dict[str, Any]
• budget · method · L574-L581 — def budget(self, root_frame_id: str) -> dict[str, Any] | None
• _project_locked · method · L583-L619 — def _project_locked( self, root_frame_id: str, *, include_text: bool ) -> dict[str, Any]
• _normalize_child · method · L621-L687 — def _normalize_child( self, row: sqlite3.Row, *, include_text: bool ) -> dict[str, Any]
• _persist_message_locked · method · L689-L724 — def _persist_message_locked( self, root: str, child_id: str, owner: str, runner: str, message: Mapping[str, Any], ) -> None
• _lease_locked · method · L726-L734 — def _lease_locked(self, root: str, owner: str, runner: str) -> sqlite3.Row
• _child_locked · method · L736-L743 — def _child_locked( self, root: str, child_id: str, *, include_text: bool ) -> dict[str, Any] | None
• _budget_locked · method · L745-L751 — def _budget_locked(self, root: str) -> dict[str, Any]
• _budget_from · method · L754-L764 — def _budget_from(row: sqlite3.Row) -> dict[str, Any]
• _required · function · L767-L770 — def _required(name: str, value: str) -> str
• _text · function · L773-L783 — def _text(value: Any, limit: int) -> str | None
• _public · function · L786-L811 — def _public(value: Any, depth: int = 0) -> Any
• _encode · function · L814-L825 — def _encode(value: Any, limit: int) -> str
• _encode_result · function · L828-L829 — def _encode_result(value: Any) -> str
• _decode · function · L832-L838 — def _decode(value: str | None) -> Any
• _float · function · L841-L842 — def _float(value: Any) -> float | None
• _positive · function · L845-L849 — def _positive(value: Any) -> int | None