From ebcabe29ca0d5ed95a6fec1f44b4505afe799798 Mon Sep 17 00:00:00 2001 From: yangdx Date: Mon, 23 Jun 2025 18:46:01 +0800 Subject: [PATCH] Remove duplicated graph db lock --- lightrag/lightrag.py | 30 ++++++++++++------------------ 1 file changed, 12 insertions(+), 18 deletions(-) diff --git a/lightrag/lightrag.py b/lightrag/lightrag.py index 820dd527..287ed5ee 100644 --- a/lightrag/lightrag.py +++ b/lightrag/lightrag.py @@ -1901,15 +1901,12 @@ Rebuilt: {len(entities_to_rebuild)} entities, {len(relationships_to_rebuild)} re """ from .utils_graph import adelete_by_entity - # Use graph database lock to ensure atomic merges and updates - graph_db_lock = get_graph_db_lock(enable_logging=False) - async with graph_db_lock: - return await adelete_by_entity( - self.chunk_entity_relation_graph, - self.entities_vdb, - self.relationships_vdb, - entity_name, - ) + return await adelete_by_entity( + self.chunk_entity_relation_graph, + self.entities_vdb, + self.relationships_vdb, + entity_name, + ) def delete_by_entity(self, entity_name: str) -> None: loop = always_get_an_event_loop() @@ -1924,15 +1921,12 @@ Rebuilt: {len(entities_to_rebuild)} entities, {len(relationships_to_rebuild)} re """ from .utils_graph import adelete_by_relation - # Use graph database lock to ensure atomic merges and updates - graph_db_lock = get_graph_db_lock(enable_logging=False) - async with graph_db_lock: - return await adelete_by_relation( - self.chunk_entity_relation_graph, - self.relationships_vdb, - source_entity, - target_entity, - ) + return await adelete_by_relation( + self.chunk_entity_relation_graph, + self.relationships_vdb, + source_entity, + target_entity, + ) def delete_by_relation(self, source_entity: str, target_entity: str) -> None: loop = always_get_an_event_loop()