diff --git a/cognee/infrastructure/databases/graph/kuzu/adapter.py b/cognee/infrastructure/databases/graph/kuzu/adapter.py index 66dcc7bbe..bb5308859 100644 --- a/cognee/infrastructure/databases/graph/kuzu/adapter.py +++ b/cognee/infrastructure/databases/graph/kuzu/adapter.py @@ -258,7 +258,10 @@ class KuzuAdapter(GraphDBInterface): if self.open_connections == 0: self.close() - return result + return result + else: + result = await loop.run_in_executor(self.executor, blocking_query) + return result def close(self): if self.connection: