atransform() — langchain Function Reference

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

Function python LangChainCore Runnables calls 2 called by 2

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  dd47e0f6_01d1_bac7_e0fb_611561853fa8["atransform()"]
  17599172_8889_afc6_2237_4429f3439071["RunnableParallel"]
  dd47e0f6_01d1_bac7_e0fb_611561853fa8 -->|defined in| 17599172_8889_afc6_2237_4429f3439071
  521ad83e_0c69_b97d_0d8e_466b6e030ed2["astream()"]
  521ad83e_0c69_b97d_0d8e_466b6e030ed2 -->|calls| dd47e0f6_01d1_bac7_e0fb_611561853fa8
  9c31698a_2e43_9df9_b618_11fd9b0d1d60["atransform()"]
  9c31698a_2e43_9df9_b618_11fd9b0d1d60 -->|calls| dd47e0f6_01d1_bac7_e0fb_611561853fa8
  7d532bc6_d85b_8af5_f142_583cf8e684f6["_atransform_stream_with_config()"]
  dd47e0f6_01d1_bac7_e0fb_611561853fa8 -->|calls| 7d532bc6_d85b_8af5_f142_583cf8e684f6
  9c31698a_2e43_9df9_b618_11fd9b0d1d60["atransform()"]
  dd47e0f6_01d1_bac7_e0fb_611561853fa8 -->|calls| 9c31698a_2e43_9df9_b618_11fd9b0d1d60
  style dd47e0f6_01d1_bac7_e0fb_611561853fa8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 4067–4076

    async def atransform(
        self,
        input: AsyncIterator[Input],
        config: RunnableConfig | None = None,
        **kwargs: Any,
    ) -> AsyncIterator[dict[str, Any]]:
        async for chunk in self._atransform_stream_with_config(
            input, self._atransform, config, **kwargs
        ):
            yield chunk