Start many tasks concurrently but with a limit of how many tasks can run at a time.

gather_with_concurrency.py

import asyncio

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

    async def concurrent_task(task):
        async with semaphore:
            await task

    await asyncio.gather(*(concurrent_task(task) for task in tasks))