|
@@ -413,7 +413,7 @@ async def check_package_urls(packages):
|
|
|
async with aiohttp.ClientSession(connector=connector, trust_env=True) as sess:
|
|
|
packages = [p for p in packages if p.status['url'][0] == 'ok']
|
|
|
for pkg in packages:
|
|
|
- tasks.append(check_url_status(sess, pkg, len(packages)))
|
|
|
+ tasks.append(asyncio.ensure_future(check_url_status(sess, pkg, len(packages))))
|
|
|
await asyncio.wait(tasks)
|
|
|
|
|
|
|
|
@@ -531,7 +531,7 @@ async def check_package_latest_version(packages):
|
|
|
async with aiohttp.ClientSession(connector=connector, trust_env=True) as sess:
|
|
|
packages = [p for p in packages if p.has_valid_infra]
|
|
|
for pkg in packages:
|
|
|
- tasks.append(check_package_latest_version_get(sess, pkg, len(packages)))
|
|
|
+ tasks.append(asyncio.ensure_future(check_package_latest_version_get(sess, pkg, len(packages))))
|
|
|
await asyncio.wait(tasks)
|
|
|
|
|
|
|