atransform() — langchain Function Reference

Architecture documentation for the atransform() function in base.py from the langchain codebase.

Function python LangChainCore Runnables calls 2

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  9fd2d82a_5f60_914f_a756_f78c796456f8["atransform()"]
  9a777f9f_fc96_a4c7_ebd5_632b655b53ae["RunnableBindingBase"]
  9fd2d82a_5f60_914f_a756_f78c796456f8 -->|defined in| 9a777f9f_fc96_a4c7_ebd5_632b655b53ae
  ff1cc135_559f_c237_6539_8d8ba268c8e8["_merge_configs()"]
  9fd2d82a_5f60_914f_a756_f78c796456f8 -->|calls| ff1cc135_559f_c237_6539_8d8ba268c8e8
  3673596e_21a0_2e75_b2b6_4e0b42a59cee["atransform()"]
  9fd2d82a_5f60_914f_a756_f78c796456f8 -->|calls| 3673596e_21a0_2e75_b2b6_4e0b42a59cee
  style 9fd2d82a_5f60_914f_a756_f78c796456f8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 5918–5929

    async def atransform(
        self,
        input: AsyncIterator[Input],
        config: RunnableConfig | None = None,
        **kwargs: Any,
    ) -> AsyncIterator[Output]:
        async for item in self.bound.atransform(
            input,
            self._merge_configs(config),
            **{**self.kwargs, **kwargs},
        ):
            yield item