openai4s/storage/artifact_observations.py

• create_artifact_observations_schema · function · L83-L85 — def create_artifact_observations_schema(conn: sqlite3.Connection) -> None
• _decode_input_ids · function · L88-L95 — def _decode_input_ids(raw: Any) -> list[str]
• _merge_input_ids · function · L98-L112 — def _merge_input_ids(current: Any, incoming: list[Any]) -> str
• ArtifactObservationRepository · class · L115-L314 — class ArtifactObservationRepository
• init · method · L118-L119 — def init(self, connection: sqlite3.Connection) -> None
• upsert · method · L121-L210 — def upsert( self, *, artifact_id: str, version_id: str, producing_cell_id: str, frame_id: str | None, capture_kind: str, filename: str, content_type: str | None, size_bytes: int, checksum: str | None, path: str, snapshot_path: str | None, env_snapshot_id: str | None, source: str | None, input_version_ids: list[Any], now: int, ) -> dict
• list · method · L212-L238 — def list( self, *, artifact_id: str | None = None, version_id: str | None = None, ) -> list[dict]
• cursor · method · L240-L262 — def cursor( self, *, root_frame_id: str | None = None, project_id: str | None = None, ) -> int
• since · method · L264-L314 — def since( self, cursor: int, *, root_frame_id: str | None, project_id: str, limit: int = 1000, ) -> list[dict]