Method limited_atom

tasks/AutoTTS/code/main.py:76–81

(question, context=None)

        semaphore = asyncio.Semaphore(self.max_concurrent)

        async def limited_atom(question, context=None):
            async with semaphore:
                if context is not None:
                    return await atom(question, context)
                else:
                    return await atom(question)

        tasks = []