Function sem_task

src/wechaty/utils/async_helper.py:29–31

(task: Task)

    semaphore = asyncio.Semaphore(n_task)

    async def sem_task(task: Task) -> Any:
        async with semaphore:
            return await task
    return await asyncio.gather(*(sem_task(task) for task in tasks))