From a4a0643ad014fa1fa1919df0034f5624a20571af Mon Sep 17 00:00:00 2001 From: yangdx Date: Mon, 28 Apr 2025 23:21:07 +0800 Subject: [PATCH] Enable graph_db_lock log --- lightrag/operate.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/lightrag/operate.py b/lightrag/operate.py index 4f828b6b..7543e6ba 100644 --- a/lightrag/operate.py +++ b/lightrag/operate.py @@ -508,8 +508,6 @@ async def merge_nodes_and_edges( # Get lock manager from shared storage from .kg.shared_storage import get_graph_db_lock - graph_db_lock = get_graph_db_lock(enable_logging=False) - # Collect all nodes and edges from all chunks all_nodes = defaultdict(list) all_edges = defaultdict(list) @@ -530,6 +528,7 @@ async def merge_nodes_and_edges( # Merge nodes and edges # Use graph database lock to ensure atomic merges and updates + graph_db_lock = get_graph_db_lock(enable_logging=True) async with graph_db_lock: async with pipeline_status_lock: log_message = (