pengjunjie/ragflow
1
0
Fork 1
mirror of https://github.com/infiniflow/ragflow.git synced 2025-12-08 20:42:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

Revert PR#11151 (#11196)

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

Revert PR#11151

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)
This commit is contained in:
Zhichang Yu
2025-11-12 11:58:02 +08:00
committed by GitHub
parent d226764ed0
commit bacc9d3ab9
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
rag/utils/infinity_conn.py
View File

@ -156,7 +156,6 @@ class InfinityConnection(DocStoreConnection):
msg = f"Infinity {infinity_uri} is unhealthy in 120s." msg = f"Infinity {infinity_uri} is unhealthy in 120s."
logger.error(msg) logger.error(msg)
raise Exception(msg) raise Exception(msg)
self.column_vec_patt = re.compile(r"q_(?P<vector_size>\d+)_vec")
logger.info(f"Infinity {infinity_uri} is healthy.") logger.info(f"Infinity {infinity_uri} is healthy.")
def _migrate_db(self, inf_conn): def _migrate_db(self, inf_conn):
@ -324,8 +323,7 @@ class InfinityConnection(DocStoreConnection):
output.append(score_func) output.append(score_func)
if PAGERANK_FLD not in output: if PAGERANK_FLD not in output:
output.append(PAGERANK_FLD) output.append(PAGERANK_FLD)
output = [f for f in output if f != "_score" and self.column_vec_patt.match(f) is None] output = [f for f in output if f != "_score"]
logger.info(f"infinity output fields: {output}")
if limit <= 0: if limit <= 0:
# ElasticSearch default limit is 10000 # ElasticSearch default limit is 10000
limit = 10000 limit = 10000