|
|
@@ -609,6 +609,7 @@ async def extract(request: ExtractRequest):
|
|
|
update_extract_status(requestId, 1)
|
|
|
# 执行Agent
|
|
|
result = execute_agent_with_api(json.dumps({"query_word": query, "request_id": requestId}))
|
|
|
+ update_extract_status(requestId, 2)
|
|
|
finally:
|
|
|
# 无论成功失败，都从运行集合中移除
|
|
|
async with RUNNING_LOCK:
|
丁云鹏