mirror of
https://github.com/trustgraph-ai/trustgraph.git
synced 2026-05-17 19:35:13 +02:00
a2dde9cafb
Cassandra triples services were using syncronous EntityCentricKnowledgeGraph methods from async contexts, and connection state was managed with threading.local which is wrong for asyncio coroutines sharing a single thread. Qdrant services had no async wrapping at all, blocking the event loop on every network call. Rows services had unprotected shared state mutations across concurrent coroutines. - Add async methods to EntityCentricKnowledgeGraph (async_insert, async_get_s/p/o/sp/po/os/spo/all, async_collection_exists, async_create_collection, async_delete_collection) using the existing cassandra_async.async_execute bridge - Rewrite triples write + query services: replace threading.local with asyncio.Lock + dict cache for per-workspace connections, use async ECKG methods for all data operations, keep asyncio.to_thread only for one-time blocking ECKG construction - Wrap all Qdrant calls in asyncio.to_thread across all 6 services (doc/graph/row embeddings write + query), add asyncio.Lock + set cache for collection existence checks - Add asyncio.Lock to rows write + query services to protect shared state (schemas, sessions, config caches) from concurrent mutation - Update all affected tests to match new async patterns |
||
|---|---|---|
| .. | ||
| conftest.py | ||
| test_cassandra_config_integration.py | ||
| test_cassandra_storage_logic.py | ||
| test_doc_embeddings_milvus_storage.py | ||
| test_doc_embeddings_pinecone_storage.py | ||
| test_doc_embeddings_qdrant_storage.py | ||
| test_graph_embeddings_milvus_storage.py | ||
| test_graph_embeddings_pinecone_storage.py | ||
| test_graph_embeddings_qdrant_storage.py | ||
| test_memgraph_workspace_collection_isolation.py | ||
| test_neo4j_workspace_collection_isolation.py | ||
| test_row_embeddings_qdrant_storage.py | ||
| test_rows_cassandra_storage.py | ||
| test_triples_cassandra_storage.py | ||
| test_triples_falkordb_storage.py | ||
| test_triples_memgraph_storage.py | ||
| test_triples_neo4j_storage.py | ||