How to use aiomultiprocess?

Question

I found this package aiomultiprocess that seems like it can do both multiprocessing and asyncio.

from aiohttp import request
from aiomultiprocess import Pool


async def get(url):
    async with request("GET", url) as response:
        return await response.text("utf-8")


async def main():
    urls = ["https://jreese.sh", "https://www.google.com", ]
    async with Pool() as pool:
        async for result in pool.map(get, urls):
            print(result)

Trying to run the sample code, though, does absolutely nothing.

Trying to call the main() gives me an error RuntimeWarning: coroutine 'main' was never awaited. I can't find an actual example of how to trigger the code.

The only other question about this isn't answered.

Answer 1

The aiomultiprocess documentation example does not cover how to call the loop. The function needs to be called via asyncio.

import asyncio
from aiohttp import request
from aiomultiprocess import Pool


async def get(url):
    async with request("GET", url) as response:
        return await response.read()


async def main():
    urls = ["https://jreese.sh", "https://www.google.com", ]
    async with Pool() as pool:
        async for result in pool.map(get, urls):
            print(result)
            
if __name__ == '__main__':
    # for Python 3.7
    asyncio.run(main())
    
    # for Python 3.6
    # loop = asyncio.get_event_loop()
    # loop.run_until_complete(main())