def fixture_medias(event_loop):
if os.environ.get('FORCE_IPV4', False):
connector = aiohttp.TCPConnector(family=socket.AF_INET)
else:
connector = aiohttp.TCPConnector()
with aiohttp.ClientSession(loop=event_loop,
connector=connector) as session:
task = asyncio.gather(*[media.download(session=session)
for media in medias.values()])
event_loop.run_until_complete(task)
return medias
评论列表
文章目录