Learning asyncio: “coroutine was never awaited” warning error

by

You made faire_toutes_les_requetes_sans_bloquer an awaitable function, a coroutine, by using async def.

When you call an awaitable function, you create a new coroutine object. The code inside the function won’t run until you then await on the function or run it as a task:

>>> async def foo():
...     print("Running the foo coroutine")
...
>>> foo()
<coroutine object foo at 0x10b186348>
>>> import asyncio
>>> asyncio.run(foo())
Running the foo coroutine

You want to keep that function synchronous, because you don’t start the loop until inside that function:

def faire_toutes_les_requetes_sans_bloquer():
    loop = asyncio.get_event_loop()
    # ...
    loop.close()
    print("Fin de la boucle !")

However, you are also trying to use a aiophttp.ClientSession() object, and that’s an asynchronous context manager, you are expected to use it with async with, not just with, and so has to be run in aside an awaitable task. If you use with instead of async with a TypeError("Use async with instead") exception will be raised.

That all means you need to move the loop.run_until_complete() call out of your faire_toutes_les_requetes_sans_bloquer() function, so you can keep that as the main task to be run; you can call and await on asycio.gather() directly then:

async def faire_toutes_les_requetes_sans_bloquer():
    async with aiohttp.ClientSession() as session:
        futures = [requete_sans_bloquer(x, session) for x in range(10)]
        await asyncio.gather(*futures)
    print("Fin de la boucle !")

print("Non bloquant : ")
start = datetime.datetime.now()
asyncio.run(faire_toutes_les_requetes_sans_bloquer())
exec_time = (datetime.datetime.now() - start).seconds
print(f"Pour faire 10 requêtes, ça prend {exec_time}s\n")

I used the new asyncio.run() function (Python 3.7 and up) to run the single main task. This creates a dedicated loop for that top-level coroutine and runs it until complete.

Next, you need to move the closing ) parenthesis on the await resp.json() expression:

uid = (await response.json())['uuid']

You want to access the 'uuid' key on the result of the await, not the coroutine that response.json() produces.

With those changes your code works, but the asyncio version finishes in sub-second time; you may want to print microseconds:

exec_time = (datetime.datetime.now() - start).total_seconds()
print(f"Pour faire 10 requêtes, ça prend {exec_time:.3f}s\n")

On my machine, the synchronous requests code in about 4-5 seconds, and the asycio code completes in under .5 seconds.

More Related Contents:

  1. How to combine python asyncio with threads?
  2. How can I call an async function without await?
  3. How can I wrap a synchronous function in an async coroutine?
  4. How to call an async function without await?
  5. aiohttp: set maximum number of requests per second
  6. aiohttp: rate limiting parallel requests
  7. Exception event loop is closed with aiohttp and asyncio in python 3.8
  8. When to use and when not to use Python 3.5 `await` ?
  9. “Fire and forget” python async/await
  10. Asynchronous method call in Python?
  11. multiprocessing vs multithreading vs asyncio in Python 3
  12. Asyncio.gather vs asyncio.wait
  13. When using asyncio, how do you allow all running tasks to finish before shutting down the event loop
  14. Timeout for python coroutines
  15. “Asyncio Event Loop is Closed” when getting loop
  16. Can an asyncio event loop run in the background without suspending the Python interpreter?
  17. How do I run Python asyncio code in a Jupyter notebook?
  18. Combine awaitables like Promise.all
  19. What kind of problems (if any) would there be combining asyncio with multiprocessing?
  20. How to test Python 3.4 asyncio code?
  21. How to use ‘yield’ inside async function?
  22. asyncio: Is it possible to cancel a future been run by an Executor?
  23. Mocking async call in python 3.5
  24. Why can I only use the await keyword inside of async function?
  25. How to do multiprocessing in FastAPI
  26. How to set class attribute with await in __init__
  27. How can I await inside future-like object’s __await__?
  28. Prompt for user input using python asyncio.create_server instance
  29. Why am I getting NotImplementedError with async and await on Windows?
  30. how to add a coroutine to a running asyncio loop?

Leave a Comment