diff --git a/rag/app/table.py b/rag/app/table.py index aca1bbfbf8045e5d8c6354c7a5f31e4178b51301..29fa25461ab925f636319aca565581b86df4a9d4 100644 --- a/rag/app/table.py +++ b/rag/app/table.py @@ -223,8 +223,8 @@ def chunk(filename, binary=None, from_page=0, to_page=10000000000, continue if not str(row[clmns[j]]): continue - #if pd.isna(row[clmns[j]]): - # continue + if pd.isna(row[clmns[j]]): + continue fld = clmns_map[j][0] d[fld] = row[clmns[j]] if clmn_tys[j] != "text" else huqie.qie( row[clmns[j]]) diff --git a/rag/utils/es_conn.py b/rag/utils/es_conn.py index 2dd02bd68d0282e9adf9a1cd67603307a6afb40a..a3ceaf36de483e5dd9e802c09202520c3a8b0608 100644 --- a/rag/utils/es_conn.py +++ b/rag/utils/es_conn.py @@ -2,6 +2,7 @@ import re import json import time import copy + import elasticsearch from elastic_transport import ConnectionTimeout from elasticsearch import Elasticsearch