fix async

This commit is contained in:
jxxghp 2023-07-09 18:34:05 +08:00
parent 5466287783
commit 812dc991e3

View File

@ -21,12 +21,12 @@ def start_message_chain(body: Any, form: Any, args: Any):
@router.post("/", summary="接收用户消息", response_model=schemas.Response) @router.post("/", summary="接收用户消息", response_model=schemas.Response)
def user_message(background_tasks: BackgroundTasks, request: Request): async def user_message(background_tasks: BackgroundTasks, request: Request):
""" """
用户消息响应 用户消息响应
""" """
body = request.body() body = await request.body()
form = request.form() form = await request.form()
args = request.query_params args = request.query_params
background_tasks.add_task(start_message_chain, body, form, args) background_tasks.add_task(start_message_chain, body, form, args)
return schemas.Response(success=True) return schemas.Response(success=True)