river_tao/OneForAll-mirror
1
0
Fork 0
mirror of https://github.com/shmilylty/OneForAll.git synced 2026-08-26 12:57:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

改用ensure_future

Browse Source
This commit is contained in:
Jing Ling
2020-08-17 14:55:24 +08:00
parent 240fd51083
commit ef652aa3fa
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/request.py
+1 -3
View File
@@ -223,9 +223,7 @@ async def bulk_request(data, port):
tasks = [] tasks = []
for num, data in enumerate(to_req_data): for num, data in enumerate(to_req_data):
url = data.get('url') url = data.get('url')
name = f'RequestTask-{num}' task = asyncio.ensure_future(fetch(session, method, url))
task = asyncio.create_task(fetch(session, method, url), name=name)
logger.log('DEBUG', f'RequestTask-{num} {url}')
task.add_done_callback(functools.partial(request_callback, task.add_done_callback(functools.partial(request_callback,
index=num, index=num,
datas=to_req_data)) datas=to_req_data))