|
@@ -598,17 +598,10 @@ async def process_request_background(request_id: str):
|
|
|
extraction_requests: set = set()
|
|
|
|
|
|
@app.post("/extract")
|
|
|
-<<<<<<< HEAD
|
|
|
async def extract(request: ExtractRequest):
|
|
|
try:
|
|
|
requestId = request.requestId
|
|
|
query = request.query
|
|
|
-=======
|
|
|
-async def extract(request: ExpandRequest, background_tasks: BackgroundTasks):
|
|
|
- try:
|
|
|
- request_id = request.requestId
|
|
|
- query_word = request.query
|
|
|
->>>>>>> 1c36a03 (clean_agent)
|
|
|
# 检查请求是否已经在处理中
|
|
|
async with RUNNING_LOCK:
|
|
|
if requestId in extraction_requests:
|