atransform() — langchain Function Reference

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

Function python LangChainCore Runnables calls 1 called by 3

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  eb798efb_a553_9e1b_0bc9_415bcf874209["atransform()"]
  e893b6ae_1c28_41f1_aa8b_a66d0f779312["RunnableAssign"]
  eb798efb_a553_9e1b_0bc9_415bcf874209 -->|defined in| e893b6ae_1c28_41f1_aa8b_a66d0f779312
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd["astream()"]
  29e5a61e_3192_fcb1_8408_ac325ae0e3cd -->|calls| eb798efb_a553_9e1b_0bc9_415bcf874209
  68f322b4_1349_271a_408d_e2eb04ed643e["atransform()"]
  68f322b4_1349_271a_408d_e2eb04ed643e -->|calls| eb798efb_a553_9e1b_0bc9_415bcf874209
  0f3c771a_cfa4_959e_f282_59837b63e8cf["atransform()"]
  0f3c771a_cfa4_959e_f282_59837b63e8cf -->|calls| eb798efb_a553_9e1b_0bc9_415bcf874209
  68f322b4_1349_271a_408d_e2eb04ed643e["atransform()"]
  eb798efb_a553_9e1b_0bc9_415bcf874209 -->|calls| 68f322b4_1349_271a_408d_e2eb04ed643e
  style eb798efb_a553_9e1b_0bc9_415bcf874209 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 637–646

    async def atransform(
        self,
        input: AsyncIterator[dict[str, Any]],
        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