atransform() — langchain Function Reference

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

Function python LangChainCore Runnables calls 1 called by 2

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  6b0af8a6_40de_913f_d715_e591ebb530c1["atransform()"]
  c4bf8d59_69f9_f8e5_efba_837c20df2360["RunnableSequence"]
  6b0af8a6_40de_913f_d715_e591ebb530c1 -->|defined in| c4bf8d59_69f9_f8e5_efba_837c20df2360
  1cbe8031_cce3_0270_34d7_1b83f106f5f2["astream()"]
  1cbe8031_cce3_0270_34d7_1b83f106f5f2 -->|calls| 6b0af8a6_40de_913f_d715_e591ebb530c1
  3673596e_21a0_2e75_b2b6_4e0b42a59cee["atransform()"]
  3673596e_21a0_2e75_b2b6_4e0b42a59cee -->|calls| 6b0af8a6_40de_913f_d715_e591ebb530c1
  7d532bc6_d85b_8af5_f142_583cf8e684f6["_atransform_stream_with_config()"]
  6b0af8a6_40de_913f_d715_e591ebb530c1 -->|calls| 7d532bc6_d85b_8af5_f142_583cf8e684f6
  style 6b0af8a6_40de_913f_d715_e591ebb530c1 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 3537–3549

    async def atransform(
        self,
        input: AsyncIterator[Input],
        config: RunnableConfig | None = None,
        **kwargs: Any | None,
    ) -> AsyncIterator[Output]:
        async for chunk in self._atransform_stream_with_config(
            input,
            self._atransform,
            patch_config(config, run_name=(config or {}).get("run_name") or self.name),
            **kwargs,
        ):
            yield chunk