gather_with_concurrency#

async langchain_core.runnables.utils.gather_with_concurrency(

n: int | None,

*coros: Coroutine,

) → list[source]#

Gather coroutines with a limit on the number of concurrent coroutines.

Parameters:

• n (Union[int, None]) – The number of coroutines to run concurrently.

• *coros (Coroutine) – The coroutines to run.

Returns:

The results of the coroutines.

Return type:

list