From 550283c356143797ac633274301347567793a2b3 Mon Sep 17 00:00:00 2001 From: Wang Qi Date: Fri, 7 Aug 2026 14:29:01 +0800 Subject: [PATCH] Fix generate graph error (#17966) --- rag/advanced_rag/knowlege_compile/structure.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/rag/advanced_rag/knowlege_compile/structure.py b/rag/advanced_rag/knowlege_compile/structure.py index 2284518039..6b07b68e53 100644 --- a/rag/advanced_rag/knowlege_compile/structure.py +++ b/rag/advanced_rag/knowlege_compile/structure.py @@ -1297,7 +1297,11 @@ def _struct_rebuild_doc_storage_doc( async def _struct_reembed_payload(payload: dict, embd_mdl): """Re-encode a merged payload's description with embd_mdl and return the vector.""" text = _struct_payload_description(payload) - vecs = await _struct_embed(embd_mdl, [text]) + try: + vecs = await _struct_embed(embd_mdl, [text]) + except Exception: + logging.exception("structure merge: failed to re-embed merged payload") + return None return vecs[0] if vecs else None @@ -2017,8 +2021,8 @@ async def _struct_local_dedup( ) new_vec = await _struct_reembed_payload(merged_payload, embd_mdl) if new_vec is None: - # Re-embed failed: keep existing, drop incoming silently. - dropped += 1 + # Keep both candidates when the merged row cannot be embedded. + kept.append(incoming) continue rebuilt = _struct_rebuild_doc_storage_doc( merged_payload,