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 1

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  dac5e541_1204_9fcb_a2a6_e9b9b5845c0c["atransform()"]
  c6a370e4_a02a_c56a_38eb_7ca734dcbfea["RunnableLambda"]
  dac5e541_1204_9fcb_a2a6_e9b9b5845c0c -->|defined in| c6a370e4_a02a_c56a_38eb_7ca734dcbfea
  dea85c11_55cc_7027_52b2_ae175ec1a0cc["astream()"]
  dea85c11_55cc_7027_52b2_ae175ec1a0cc -->|calls| dac5e541_1204_9fcb_a2a6_e9b9b5845c0c
  7d532bc6_d85b_8af5_f142_583cf8e684f6["_atransform_stream_with_config()"]
  dac5e541_1204_9fcb_a2a6_e9b9b5845c0c -->|calls| 7d532bc6_d85b_8af5_f142_583cf8e684f6
  9c31698a_2e43_9df9_b618_11fd9b0d1d60["atransform()"]
  dac5e541_1204_9fcb_a2a6_e9b9b5845c0c -->|calls| 9c31698a_2e43_9df9_b618_11fd9b0d1d60
  style dac5e541_1204_9fcb_a2a6_e9b9b5845c0c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 5244–5256

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