diff --git a/lightrag/kg/neo4j_impl.py b/lightrag/kg/neo4j_impl.py index cf3c024f..34226df7 100644 --- a/lightrag/kg/neo4j_impl.py +++ b/lightrag/kg/neo4j_impl.py @@ -520,7 +520,7 @@ class Neo4JStorage(BaseGraphStorage): edges.append((source_label, target_label)) await results.consume() # Ensure results are consumed - return edges if edges else None + return edges except Exception as e: logger.error(f"Error getting edges for node {node_label}: {str(e)}") await results.consume() # Ensure results are consumed even on error