[Bug] Xinference rerank 吞掉上游异常并返回空列表，导致知识库丢失已融合的检索结果 #10000

import ast, asyncio, abc, copy, functools, re, time, dataclasses
from pathlib import Path
from types import SimpleNamespace as NS
from unittest.mock import AsyncMock, Mock
ROOT = Path.cwd()
def load(path, names, env=None):
    tree = ast.parse((ROOT/path).read_text())
    selected = [n for n in tree.body if isinstance(n, (ast.ClassDef, ast.FunctionDef, ast.AsyncFunctionDef)) and n.name in names]
    scope = dict(__name__='__main__', asyncio=asyncio, abc=abc, copy=copy, functools=functools, re=re, time=time, dataclass=dataclasses.dataclass, logger=Mock(), BaseChunker=object, deprecated=lambda **kw: lambda f:f)
    scope.update(env or {})
    mod=ast.Module(body=[ast.ImportFrom(module='__future__', names=[ast.alias(name='annotations')],level=0), *selected],type_ignores=[])
    exec(compile(ast.fix_missing_locations(mod),str(ROOT/path),'exec'),scope)
    return scope
async def main():
    class Base: pass
    s=load('astrbot/core/provider/sources/xinference_rerank_source.py',['XinferenceRerankProvider'],{'RerankProvider':Base,'register_provider_adapter':lambda *a,**k:lambda c:c,'ProviderType':NS(RERANK='rerank')})
    provider=object.__new__(s['XinferenceRerankProvider']); provider.model=NS(rerank=AsyncMock(side_effect=RuntimeError('upstream down')))
    s=load('astrbot/core/knowledge_base/retrieval/manager.py',['RetrievalResult','RetrievalManager'])
    fused=NS(chunk_id='chunk1',doc_id='doc1',kb_id='kb1',content='known answer',score=.8,chunk_index=0)
    db=NS(get_documents_with_metadata_batch=AsyncMock(return_value={'doc1':{'document':NS(doc_name='doc'),'knowledge_base':NS(kb_name='kb')}}))
    mgr=s['RetrievalManager'](NS(retrieve=AsyncMock(return_value=[])),NS(fuse=AsyncMock(return_value=[fused])),db)
    mgr._dense_retrieve=AsyncMock(return_value=[])
    kb=NS(top_k_dense=50,top_k_sparse=50,top_m_final=5,rerank_provider_id='rp')
    result=await mgr.retrieve('query',['kb1'],{'kb1':NS(kb=kb,vec_db=NS(rerank_provider=provider))})
    print('6 failed Xinference rerank: fused candidates=1, returned=',len(result))
    assert result==[]
    provider.rerank=AsyncMock(side_effect=RuntimeError('propagated failure'))
    result=await mgr.retrieve('query',['kb1'],{'kb1':NS(kb=kb,vec_db=NS(rerank_provider=provider))})
    assert len(result)==1
asyncio.run(main())