refac: Implicit asyncio create_task

This commit is contained in:
tth37 2025-04-29 00:20:55 +08:00
parent 5b9c1de3d1
commit cf2d7de873

View File

@ -366,21 +366,17 @@ async def chat_web_search_handler(
} }
) )
web_search_tasks = [ gathered_results = await asyncio.gather(
asyncio.create_task( *(
process_web_search( process_web_search(
request, request,
SearchForm( SearchForm(**{"query": searchQuery}),
**{
"query": searchQuery,
}
),
user=user, user=user,
) )
)
for searchQuery in queries for searchQuery in queries
] ),
gathered_results = await asyncio.gather(*web_search_tasks, return_exceptions=True) return_exceptions=True,
)
for searchQuery, results in zip(queries, gathered_results): for searchQuery, results in zip(queries, gathered_results):
try: try: