1.3 修改bug
This commit is contained in:
parent
14543f9663
commit
6f8a98c518
@ -52,9 +52,9 @@ def fetch_procurement_reqs(procurement_path, invalid_path):
|
||||
# 使用 ThreadPoolExecutor 并行处理 get_technical_requirements 和 get_business_requirements
|
||||
with concurrent.futures.ThreadPoolExecutor() as executor:
|
||||
# 提交任务给线程池
|
||||
future_technical = executor.submit(get_technical_requirements, invalid_path, processed_filepath,tech_model_type)
|
||||
future_technical = executor.submit(get_technical_requirements, invalid_path, processed_filepath, tech_model_type)
|
||||
time.sleep(0.5) # 保持原有的延时
|
||||
future_business = executor.submit(get_business_requirements, procurement_path, processed_filepath,busi_model_type)
|
||||
future_business = executor.submit(get_business_requirements, procurement_path, processed_filepath, busi_model_type)
|
||||
# 获取并行任务的结果
|
||||
technical_requirements = future_technical.result()
|
||||
business_requirements = future_business.result()
|
||||
|
Loading…
x
Reference in New Issue
Block a user