|
@@ -515,7 +515,7 @@ def create_langgraph_workflow():
|
|
|
except RuntimeError:
|
|
except RuntimeError:
|
|
|
pass # 如果已经设置过，忽略错误
|
|
pass # 如果已经设置过，忽略错误
|
|
|
|
|
|
|
|
- with multiprocessing.Pool(processes=3) as pool:
|
|
|
|
|
|
|
+ with multiprocessing.Pool(processes=2) as pool:
|
|
|
logger.info(f"开始多进程处理: 数量={len(process_args)}")
|
|
logger.info(f"开始多进程处理: 数量={len(process_args)}")
|
|
|
results = pool.map(process_single_item, process_args)
|
|
results = pool.map(process_single_item, process_args)
|
|
|
|
|
|
