Issue
Below is a simple program to collect URL lengths.
import aiohttp
import asyncio
from time import perf_counter
URLS = ['http://www.cnn.com', 'http://www.huffpost.com', 'http://europe.wsj.com',
'http://www.bbc.co.uk', 'http://failfailfail.com']
async def async_load_url(url, session):
try:
async with session.get(url) as resp:
content = await resp.read()
print(f"{url!r} is {len(content)} bytes")
except IOError:
print(f"failed to load {url}")
async def main():
async with aiohttp.ClientSession() as session:
tasks = [async_load_url(url, session) for url in URLS]
await asyncio.wait(tasks)
if __name__ == "__main__":
start = perf_counter()
asyncio.run(main())
elapsed = perf_counter() - start
print(f"\nTook {elapsed} seconds")
Why is the following code failing with a runtime error with exception ignored in python 3.9? How to fix it?
Traceback is: RuntimeError: Event loop is closed
specifically with Exception ignored in: <function _ProactorBasePipeTransport.__del__ at 0x000001F8A7A713A0>
Solution
This is caused by a known issue in aiohttp on Windows, for details check out the bug at https://github.com/aio-libs/aiohttp/issues/4324
There are a couple of hacks that silence this error. The first way is to get the event loop and call run_until_complete
instead of asyncio.run(main())
like so:
asyncio.get_event_loop().run_until_complete(main())
Alternatively, changing the event loop policy to WindowsSelectorEventLoopPolicy
before calling asyncio.run(main())
also works as the problem seems to occur when using WindowsProtractorEventLoopPolicy
.
asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
asyncio.run(main())
Of course, the second solution will make your code platform specific, so be careful.
Answered By - Matt Fowler
0 comments:
Post a Comment
Note: Only a member of this blog may post a comment.