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

testing on demand connection with ci/cd

Browse source
This commit is contained in:
hajdul88 2025-10-08 10:40:30 +02:00
parent 93416cccc2
commit 57439ae8df
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
cognee/infrastructure/databases/graph/kuzu/adapter.py
View file

@ -28,7 +28,7 @@ from cognee.infrastructure.databases.cache.config import get_cache_config
logger = get_logger() logger = get_logger()
cache_config = get_cache_config() cache_config = get_cache_config()
if cache_config.caching: if not cache_config.caching:
from cognee.infrastructure.databases.cache.get_cache_engine import get_cache_engine from cognee.infrastructure.databases.cache.get_cache_engine import get_cache_engine
@ -49,7 +49,7 @@ class KuzuAdapter(GraphDBInterface):
self.db_path = db_path # Path for the database directory self.db_path = db_path # Path for the database directory
self.db: Optional[Database] = None self.db: Optional[Database] = None
self.connection: Optional[Connection] = None self.connection: Optional[Connection] = None
if cache_config.caching: if not cache_config.caching:
self.executor = ThreadPoolExecutor(max_workers=1) self.executor = ThreadPoolExecutor(max_workers=1)
self.redis_lock = get_cache_engine( self.redis_lock = get_cache_engine(
lock_key="kuzu-lock-" + str(uuid5(NAMESPACE_OID, db_path)) lock_key="kuzu-lock-" + str(uuid5(NAMESPACE_OID, db_path))
@ -244,7 +244,7 @@ class KuzuAdapter(GraphDBInterface):
logger.error(f"Query execution failed: {str(e)}") logger.error(f"Query execution failed: {str(e)}")
raise raise
if cache_config.caching: if not cache_config.caching:
async with self._connection_change_lock: async with self._connection_change_lock:
self.open_connections += 1 self.open_connections += 1
if self._is_closed: if self._is_closed: