mirror of
https://github.com/meta-llama/llama-stack.git
synced 2025-07-29 15:23:51 +00:00
updating _load_openai_vector_stores
Signed-off-by: Francisco Javier Arceo <farceo@redhat.com>
This commit is contained in:
parent
ea6173e1b0
commit
006c955aae
1 changed files with 6 additions and 2 deletions
|
@ -514,8 +514,12 @@ class SQLiteVecVectorIOAdapter(OpenAIVectorStoreMixin, VectorIO, VectorDBsProtoc
|
||||||
assert self.kvstore is not None
|
assert self.kvstore is not None
|
||||||
start_key = OPENAI_VECTOR_STORES_PREFIX
|
start_key = OPENAI_VECTOR_STORES_PREFIX
|
||||||
end_key = f"{OPENAI_VECTOR_STORES_PREFIX}\xff"
|
end_key = f"{OPENAI_VECTOR_STORES_PREFIX}\xff"
|
||||||
stored = await self.kvstore.values_in_range(start_key, end_key)
|
stored_openai_stores = await self.kvstore.values_in_range(start_key, end_key)
|
||||||
return {json.loads(s)["id"]: json.loads(s) for s in stored}
|
stores = {}
|
||||||
|
for store_data in stored_openai_stores:
|
||||||
|
store_info = json.loads(store_data)
|
||||||
|
stores[store_info["id"]] = store_info
|
||||||
|
return stores
|
||||||
|
|
||||||
async def _update_openai_vector_store(self, store_id: str, store_info: dict[str, Any]) -> None:
|
async def _update_openai_vector_store(self, store_id: str, store_info: dict[str, Any]) -> None:
|
||||||
"""Update vector store metadata in SQLite database."""
|
"""Update vector store metadata in SQLite database."""
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue