openai4s/storage/delegation_attempts.py

• DelegationRequestConflict · class · L81-L84 — class DelegationRequestConflict(RuntimeError)
• canonical_request_payload · function · L87-L92 — def canonical_request_payload(spec: Mapping[str, Any]) -> dict[str, Any]
• request_sha256 · function · L95-L103 — def request_sha256(spec: Mapping[str, Any]) -> str
• delegation_identity · function · L106-L111 — def delegation_identity(spec: Mapping[str, Any]) -> tuple[str, str] | None
• encode_payload · function · L114-L121 — def encode_payload(spec: Mapping[str, Any]) -> str
• decode_payload · function · L124-L131 — def decode_payload(raw: str | None) -> dict[str, Any]
• encode_artifact_refs · function · L134-L156 — def encode_artifact_refs(refs: Sequence[Mapping[str, Any]] | None) -> str | None
• decode_artifact_refs · function · L159-L168 — def decode_artifact_refs(raw: str | None) -> list[dict[str, Any]]
• create_delegation_request_schema · function · L171-L176 — def create_delegation_request_schema(connection: sqlite3.Connection) -> None
• new_request_id · function · L179-L180 — def new_request_id() -> str
• new_attempt_id · function · L183-L184 — def new_attempt_id() -> str
• DelegationAttemptRepository · class · L187-L417 — class DelegationAttemptRepository
• init · method · L190-L199 — def init( self, connection: sqlite3.Connection, lock: Any, *, clock_ms: Callable[[], int], ) -> None
• lookup_locked · method · L201-L213 — def lookup_locked( self, *, root_frame_id: str, parent_action_group_id: str, native_call_id: str, ) -> dict[str, Any] | None
• request_by_id_locked · method · L215-L220 — def request_by_id_locked(self, request_id: str) -> dict[str, Any] | None
• request_for_child_locked · method · L222-L235 — def request_for_child_locked( self, *, root_frame_id: str, child_id: str ) -> dict[str, Any] | None
• insert_request_locked · method · L237-L274 — def insert_request_locked( self, *, root_frame_id: str, parent_action_group_id: str, native_call_id: str, request_sha256: str, child_id: str, payload: Mapping[str, Any] | None = None, ) -> dict[str, Any]
• insert_attempt_locked · method · L276-L318 — def insert_attempt_locked( self, *, request_id: str, child_id: str, previous_attempt_id: str | None = None, state: str = "pending", ) -> dict[str, Any]
• latest_attempt_locked · method · L320-L326 — def latest_attempt_locked(self, request_id: str) -> dict[str, Any] | None
• attempt_for_child_locked · method · L328-L334 — def attempt_for_child_locked(self, child_id: str) -> dict[str, Any] | None
• update_attempt_state_locked · method · L336-L365 — def update_attempt_state_locked( self, child_id: str, state: str, *, artifact_refs: Sequence[Mapping[str, Any]] | None = None, ) -> None
• stop_live_attempts_locked · method · L367-L376 — def stop_live_attempts_locked(self, child_ids: Sequence[str]) -> None
• project_for_child_locked · method · L378-L389 — def project_for_child_locked( self, *, root_frame_id: str, child_id: str ) -> dict[str, Any]
• _request_from · method · L392-L403 — def _request_from(row: sqlite3.Row) -> dict[str, Any]
• _attempt_from · method · L406-L417 — def _attempt_from(row: sqlite3.Row) -> dict[str, Any]