gated_coro() — langchain Function Reference

Architecture documentation for the gated_coro() function in utils.py from the langchain codebase.

Function python CoreAbstractions Serialization called by 1

Entity Profile

CoreAbstractions→ Serialization→ gated_coro() — langchain Function Reference

Dependency Diagram

graph TD
  dfcca044_cfe7_25bf_db90_97c2b92175f9["gated_coro()"]
  ca66092c_447c_d201_0d3c_cfa6ca2cc9d3["utils.py"]
  dfcca044_cfe7_25bf_db90_97c2b92175f9 -->|defined in| ca66092c_447c_d201_0d3c_cfa6ca2cc9d3
  68b5bc9e_7e1f_b0a3_02e4_e149e32711ae["gather_with_concurrency()"]
  68b5bc9e_7e1f_b0a3_02e4_e149e32711ae -->|calls| dfcca044_cfe7_25bf_db90_97c2b92175f9
  style dfcca044_cfe7_25bf_db90_97c2b92175f9 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/utils.py lines 49–60

async def gated_coro(semaphore: asyncio.Semaphore, coro: Coroutine) -> Any:
    """Run a coroutine with a semaphore.

    Args:
        semaphore: The semaphore to use.
        coro: The coroutine to run.

    Returns:
        The result of the coroutine.
    """
    async with semaphore:
        return await coro