forked from phoenix-oss/llama-stack-mirror
b27c41fe39
# What does this PR do? - sqlite_vec not added to all template yet, disable test for now to unblock release cut [//]: # (If resolving an issue, uncomment and update the line below) [//]: # (Closes #[issue-number]) ## Test Plan <img width="846" alt="image" src="https://github.com/user-attachments/assets/fa896497-f37c-4cdf-bc62-21893afbd392" /> [//]: # (## Documentation)
86 lines
3.3 KiB
Python
86 lines
3.3 KiB
Python
# Copyright (c) Meta Platforms, Inc. and affiliates.
|
|
# All rights reserved.
|
|
#
|
|
# This source code is licensed under the terms described in the LICENSE file in
|
|
# the root directory of this source tree.
|
|
|
|
import random
|
|
|
|
import pytest
|
|
|
|
INLINE_VECTOR_DB_PROVIDERS = [
|
|
"faiss",
|
|
# TODO: add sqlite_vec to templates
|
|
# "sqlite_vec",
|
|
]
|
|
|
|
|
|
@pytest.fixture(scope="function")
|
|
def empty_vector_db_registry(llama_stack_client):
|
|
vector_dbs = [vector_db.identifier for vector_db in llama_stack_client.vector_dbs.list()]
|
|
for vector_db_id in vector_dbs:
|
|
llama_stack_client.vector_dbs.unregister(vector_db_id=vector_db_id)
|
|
|
|
|
|
@pytest.fixture(scope="function")
|
|
def single_entry_vector_db_registry(llama_stack_client, empty_vector_db_registry, provider_id):
|
|
vector_db_id = f"test_vector_db_{random.randint(1000, 9999)}"
|
|
llama_stack_client.vector_dbs.register(
|
|
vector_db_id=vector_db_id,
|
|
embedding_model="all-MiniLM-L6-v2",
|
|
embedding_dimension=384,
|
|
provider_id=provider_id,
|
|
)
|
|
vector_dbs = [vector_db.identifier for vector_db in llama_stack_client.vector_dbs.list()]
|
|
return vector_dbs
|
|
|
|
|
|
@pytest.mark.parametrize("provider_id", INLINE_VECTOR_DB_PROVIDERS)
|
|
def test_vector_db_retrieve(llama_stack_client, embedding_model, empty_vector_db_registry, provider_id):
|
|
# Register a memory bank first
|
|
vector_db_id = f"test_vector_db_{random.randint(1000, 9999)}"
|
|
llama_stack_client.vector_dbs.register(
|
|
vector_db_id=vector_db_id,
|
|
embedding_model=embedding_model,
|
|
embedding_dimension=384,
|
|
provider_id=provider_id,
|
|
)
|
|
|
|
# Retrieve the memory bank and validate its properties
|
|
response = llama_stack_client.vector_dbs.retrieve(vector_db_id=vector_db_id)
|
|
assert response is not None
|
|
assert response.identifier == vector_db_id
|
|
assert response.embedding_model == embedding_model
|
|
assert response.provider_id == provider_id
|
|
assert response.provider_resource_id == vector_db_id
|
|
|
|
|
|
def test_vector_db_list(llama_stack_client, empty_vector_db_registry):
|
|
vector_dbs_after_register = [vector_db.identifier for vector_db in llama_stack_client.vector_dbs.list()]
|
|
assert len(vector_dbs_after_register) == 0
|
|
|
|
|
|
@pytest.mark.parametrize("provider_id", INLINE_VECTOR_DB_PROVIDERS)
|
|
def test_vector_db_register(llama_stack_client, embedding_model, empty_vector_db_registry, provider_id):
|
|
vector_db_id = f"test_vector_db_{random.randint(1000, 9999)}"
|
|
llama_stack_client.vector_dbs.register(
|
|
vector_db_id=vector_db_id,
|
|
embedding_model=embedding_model,
|
|
embedding_dimension=384,
|
|
provider_id=provider_id,
|
|
)
|
|
|
|
vector_dbs_after_register = [vector_db.identifier for vector_db in llama_stack_client.vector_dbs.list()]
|
|
assert vector_dbs_after_register == [vector_db_id]
|
|
|
|
|
|
@pytest.mark.parametrize("provider_id", INLINE_VECTOR_DB_PROVIDERS)
|
|
def test_vector_db_unregister(llama_stack_client, single_entry_vector_db_registry, provider_id):
|
|
vector_dbs = [vector_db.identifier for vector_db in llama_stack_client.vector_dbs.list()]
|
|
assert len(vector_dbs) == 1
|
|
|
|
vector_db_id = vector_dbs[0]
|
|
llama_stack_client.vector_dbs.unregister(vector_db_id=vector_db_id)
|
|
|
|
vector_dbs = [vector_db.identifier for vector_db in llama_stack_client.vector_dbs.list()]
|
|
assert len(vector_dbs) == 0
|