abatch() — langchain Function Reference

Architecture documentation for the abatch() function in retry.py from the langchain codebase.

Function python LangChainCore Runnables called by 1

Entity Profile

LangChainCore→ Runnables→ abatch() — langchain Function Reference

Dependency Diagram

graph TD
  7dea3d8c_e973_7709_8b13_2e21005cfcf4["abatch()"]
  dcb89960_9531_c0ae_7764_c192a29f52c0["RunnableRetry"]
  7dea3d8c_e973_7709_8b13_2e21005cfcf4 -->|defined in| dcb89960_9531_c0ae_7764_c192a29f52c0
  d376a50b_f292_726b_5406_bcd22f556419["_abatch()"]
  d376a50b_f292_726b_5406_bcd22f556419 -->|calls| 7dea3d8c_e973_7709_8b13_2e21005cfcf4
  style 7dea3d8c_e973_7709_8b13_2e21005cfcf4 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/retry.py lines 366–376

    async def abatch(
        self,
        inputs: list[Input],
        config: RunnableConfig | list[RunnableConfig] | None = None,
        *,
        return_exceptions: bool = False,
        **kwargs: Any,
    ) -> list[Output]:
        return await self._abatch_with_config(
            self._abatch, inputs, config, return_exceptions=return_exceptions, **kwargs
        )