AI/ragflow
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/infiniflow/ragflow.git synced 2025-08-14 04:26:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

Ignore exception of empty index. (#5030)

Browse Source 
### What problem does this PR solve?

### Type of change


- [x] Refactoring
This commit is contained in:
Kevin Hu 2025-02-17 15:59:55 +08:00 committed by GitHub
parent 2ddf278e2d
commit 3aa5c2a699
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
api/apps/kb_app.py
View File

@ -14,7 +14,6 @@
# limitations under the License. # limitations under the License.
# #
import json import json
import logging
import os import os
from flask import request from flask import request
@ -300,11 +299,12 @@ def knowledge_graph(kb_id):
"kb_id": [kb_id], "kb_id": [kb_id],
"knowledge_graph_kwd": ["graph"] "knowledge_graph_kwd": ["graph"]
} }
obj = {"graph": {}, "mind_map": {}} obj = {"graph": {}, "mind_map": {}}
try: if not settings.docStoreConn.indexExist(search.index_name(kb.tenant_id)):
sres = settings.retrievaler.search(req, search.index_name(kb.tenant_id), [kb_id]) return get_json_result(data=obj)
except Exception as e: sres = settings.retrievaler.search(req, search.index_name(kb.tenant_id), [kb_id])
logging.exception(e) if not len(sres.ids):
return get_json_result(data=obj) return get_json_result(data=obj)
for id in sres.ids[:1]: for id in sres.ids[:1]:

2
rag/utils/es_conn.py
View File

@ -113,7 +113,7 @@ class ESConnection(DocStoreConnection):
except Exception: except Exception:
logger.exception("ESConnection.deleteIdx error %s" % (indexName)) logger.exception("ESConnection.deleteIdx error %s" % (indexName))
def indexExist(self, indexName: str, knowledgebaseId: str) -> bool: def indexExist(self, indexName: str, knowledgebaseId: str = None) -> bool:
s = Index(indexName, self.es) s = Index(indexName, self.es)
for i in range(ATTEMPT_TIME): for i in range(ATTEMPT_TIME):
try: try: