|
@@ -601,7 +601,7 @@ async def extract(request_id: str, query_word: str):
|
|
|
# 更新状态为处理中
|
|
# 更新状态为处理中
|
|
|
update_extract_status(request_id, 1)
|
|
update_extract_status(request_id, 1)
|
|
|
# 执行Agent
|
|
# 执行Agent
|
|
|
- result = execute_agent_with_api(json.dumps({"query_word":query_word, "request_id": request_id}
|
|
|
|
|
|
|
+ result = execute_agent_with_api(json.dumps({"query_word":query_word, "request_id": request_id}))
|
|
|
finally:
|
|
finally:
|
|
|
# 无论成功失败，都从运行集合中移除
|
|
# 无论成功失败，都从运行集合中移除
|
|
|
async with RUNNING_LOCK:
|
|
async with RUNNING_LOCK:
|
