From 67bcd26565e462e9dce3905e0d1f6d4f7940f274 Mon Sep 17 00:00:00 2001 From: Wenjie Zhang Date: Mon, 19 Jan 2026 16:01:27 +0800 Subject: [PATCH] =?UTF-8?q?fix(lightrag):=20=E8=BF=87=E6=BB=A4=E6=8E=89?= =?UTF-8?q?=E5=BC=95=E7=94=A8=E4=B8=8D=E5=AD=98=E5=9C=A8=E8=8A=82=E7=82=B9?= =?UTF-8?q?=E7=9A=84=E8=BE=B9=E4=BB=A5=E7=A1=AE=E4=BF=9D=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E7=BB=93=E6=9E=9C=E7=9A=84=E6=9C=89=E6=95=88=E6=80=A7=20#477?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/knowledge/adapters/lightrag.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/knowledge/adapters/lightrag.py b/src/knowledge/adapters/lightrag.py index e3c7ae71..07222f37 100644 --- a/src/knowledge/adapters/lightrag.py +++ b/src/knowledge/adapters/lightrag.py @@ -317,4 +317,12 @@ class LightRAGGraphAdapter(GraphAdapter): nodes.append(self.normalize_node(item)) node_ids.add(item.element_id) - return {"nodes": nodes, "edges": edges} + # 过滤掉引用不存在节点的边 + valid_edges = [] + for edge in edges: + source_id = edge.get("source_id") + target_id = edge.get("target_id") + if source_id in node_ids and target_id in node_ids: + valid_edges.append(edge) + + return {"nodes": nodes, "edges": valid_edges}