gmakstutis/cognee
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Update test_search_db.py

Browse source
This commit is contained in:
hajdul88 2025-12-11 19:18:11 +01:00
parent 1eb15c9f9c
commit 088e4e9f98
1 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
cognee/tests/test_search_db.py
View file

@ -26,6 +26,14 @@ logger = get_logger()
async def setup_test_environment(): async def setup_test_environment():
"""Helper function to set up test environment with data, cognify, and triplet embeddings.""" """Helper function to set up test environment with data, cognify, and triplet embeddings."""
# This test runs for multiple db settings, to run this locally set the corresponding db envs # This test runs for multiple db settings, to run this locally set the corresponding db envs
# Clear caches to ensure fresh engine instances for each test (prevents event loop issues)
from cognee.infrastructure.databases.graph.get_graph_engine import create_graph_engine
from cognee.infrastructure.databases.vector.create_vector_engine import create_vector_engine
create_graph_engine.cache_clear()
create_vector_engine.cache_clear()
logger.info("Starting test setup: pruning data and system") logger.info("Starting test setup: pruning data and system")
await cognee.prune.prune_data() await cognee.prune.prune_data()
await cognee.prune.prune_system(metadata=True) await cognee.prune.prune_system(metadata=True)
@ -71,6 +79,13 @@ async def setup_test_environment():
async def setup_test_environment_for_feedback(): async def setup_test_environment_for_feedback():
"""Helper function to set up test environment for feedback weight calculation test.""" """Helper function to set up test environment for feedback weight calculation test."""
# Clear caches to ensure fresh engine instances for each test (prevents event loop issues)
from cognee.infrastructure.databases.graph.get_graph_engine import create_graph_engine
from cognee.infrastructure.databases.vector.create_vector_engine import create_vector_engine
create_graph_engine.cache_clear()
create_vector_engine.cache_clear()
await cognee.prune.prune_data() await cognee.prune.prune_data()
await cognee.prune.prune_system(metadata=True) await cognee.prune.prune_system(metadata=True)
@ -111,12 +126,6 @@ async def test_graph_vector_engine_consistency():
f"Expected {len(edges)} edges but got {len(collection)} in Triplet_text collection" f"Expected {len(edges)} edges but got {len(collection)} in Triplet_text collection"
) )
# Cleanup
try:
await cognee.prune.prune_data()
await cognee.prune.prune_system(metadata=True)
except Exception:
pass
@pytest.mark.asyncio @pytest.mark.asyncio