From ca816f46de2307cafa179f1c4c33be7e3de2456e Mon Sep 17 00:00:00 2001 From: zy123 <646228430@qq.com> Date: Tue, 18 Feb 2025 16:11:53 +0800 Subject: [PATCH] =?UTF-8?q?2.18=20=E7=A9=BA=E7=9A=84docx=E6=97=A0=E6=B3=95?= =?UTF-8?q?=E8=A2=AB=E8=AF=86=E5=88=AB=E4=B8=BA=E9=9D=9E=E6=8B=9B=E6=A0=87?= =?UTF-8?q?=E6=96=87=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- flask_app/routes/货物标解析main.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/flask_app/routes/货物标解析main.py b/flask_app/routes/货物标解析main.py index 6aed510..01de921 100644 --- a/flask_app/routes/货物标解析main.py +++ b/flask_app/routes/货物标解析main.py @@ -11,7 +11,6 @@ from flask_app.货物标.基础信息解析货物标版 import combine_basic_inf from flask_app.general.投标人须知正文提取指定内容 import extract_from_notice from flask_app.general.截取pdf_main import truncate_pdf_multiple from concurrent.futures import as_completed, ProcessPoolExecutor -import concurrent.futures from flask_app.general.投标人须知正文条款提取成json文件 import convert_clause_to_json from flask_app.general.无效标和废标公共代码 import combine_find_invalid from flask_app.货物标.资格审查main import combine_qualification_review @@ -242,7 +241,7 @@ def goods_bid_main(output_folder, file_path, file_type, unique_id): } yield json.dumps(error_response, ensure_ascii=False) return # 停止进一步处理 - with concurrent.futures.ThreadPoolExecutor() as executor: #开启子进程，能保证运行结束后回收资源消耗 + with ProcessPoolExecutor() as executor: #开启子进程，能保证运行结束后回收资源消耗 # 立即启动不依赖 knowledge_name 和 index 的任务 futures = { 'evaluation_standards': executor.submit(fetch_evaluation_standards,processed_data['invalid_deleted_docx'], #技术评分 商务评分 @@ -266,7 +265,7 @@ def goods_bid_main(output_folder, file_path, file_type, unique_id): } # 提前处理这些不依赖的任务，按完成顺序返回 - for future in concurrent.futures.as_completed(futures.values()): #as_completed：哪个先运行结束就先返回 + for future in as_completed(futures.values()): #as_completed：哪个先运行结束就先返回 key = next(k for k, v in futures.items() if v == future) try: result = future.result()