stolichki/crawler/utils/asyncio.py

import asyncio


async def gather_with_concurrency(n, *coros):
    semaphore = asyncio.Semaphore(int(n))

    async def sem_coro(coro):
        async with semaphore:
            return await coro
    
    return await asyncio.gather(*(sem_coro(c) for c in coros))