clean_agent

agent.py

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