gardel/lightrag
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Enable graph_db_lock log

Browse Source
This commit is contained in:
yangdx
2025-04-28 23:21:07 +08:00
parent 3aef63cc65
commit a4a0643ad0
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
lightrag/operate.py
View File

@@ -508,8 +508,6 @@ async def merge_nodes_and_edges(
# Get lock manager from shared storage # Get lock manager from shared storage
from .kg.shared_storage import get_graph_db_lock 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 # Collect all nodes and edges from all chunks
all_nodes = defaultdict(list) all_nodes = defaultdict(list)
all_edges = defaultdict(list) all_edges = defaultdict(list)
@@ -530,6 +528,7 @@ async def merge_nodes_and_edges(
# Merge nodes and edges # Merge nodes and edges
# Use graph database lock to ensure atomic merges and updates # 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 graph_db_lock:
async with pipeline_status_lock: async with pipeline_status_lock:
log_message = ( log_message = (