gather_with_concurrency

async langchain_core.runnables.utils.gather_with_concurrency(n: int | None, *coros: Coroutine) → list

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

Parameters:

• n (int | None) – The number of coroutines to run concurrently.

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

Returns:

The results of the coroutines.

Return type:

list