|
|
@@ -460,8 +460,7 @@ async def extract(request: ExtractRequest):
|
|
|
# 无论成功失败，都从运行集合中移除
|
|
|
async with RUNNING_LOCK:
|
|
|
extraction_requests.discard(requestId)
|
|
|
-
|
|
|
- logger.info(f"更新请求状态成功: requestId={request_id}, result={result}")
|
|
|
+ logger.info(f"extract result={result}")
|
|
|
return {"status": "success", "result": result}
|
|
|
except Exception as e:
|
|
|
# 发生异常，更新状态为处理失败
|
丁云鹏