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 1

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  0f3c771a_cfa4_959e_f282_59837b63e8cf["atransform()"]
  8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe["RunnablePick"]
  0f3c771a_cfa4_959e_f282_59837b63e8cf -->|defined in| 8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe
  62530ed9_3d20_a587_0e13_a04ed805b3c4["astream()"]
  62530ed9_3d20_a587_0e13_a04ed805b3c4 -->|calls| 0f3c771a_cfa4_959e_f282_59837b63e8cf
  eb798efb_a553_9e1b_0bc9_415bcf874209["atransform()"]
  0f3c771a_cfa4_959e_f282_59837b63e8cf -->|calls| eb798efb_a553_9e1b_0bc9_415bcf874209
  style 0f3c771a_cfa4_959e_f282_59837b63e8cf fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 810–819

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