|
@@ -451,7 +451,8 @@ async def check_url_status(session, pkg, npkgs, retry=True):
|
|
async def check_package_urls(packages):
|
|
async def check_package_urls(packages):
|
|
tasks = []
|
|
tasks = []
|
|
connector = aiohttp.TCPConnector(limit_per_host=5)
|
|
connector = aiohttp.TCPConnector(limit_per_host=5)
|
|
- async with aiohttp.ClientSession(connector=connector, trust_env=True) as sess:
|
|
|
|
|
|
+ async with aiohttp.ClientSession(connector=connector, trust_env=True,
|
|
|
|
+ timeout=aiohttp.ClientTimeout(total=15)) as sess:
|
|
packages = [p for p in packages if p.status['url'][0] == 'ok']
|
|
packages = [p for p in packages if p.status['url'][0] == 'ok']
|
|
for pkg in packages:
|
|
for pkg in packages:
|
|
tasks.append(asyncio.ensure_future(check_url_status(sess, pkg, len(packages))))
|
|
tasks.append(asyncio.ensure_future(check_url_status(sess, pkg, len(packages))))
|