_atransform() — langchain Function Reference

Architecture documentation for the _atransform() function in passthrough.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
  07dae0e0_e299_4a3b_4925_f46bdb69bdaf["_atransform()"]
  8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe["RunnablePick"]
  07dae0e0_e299_4a3b_4925_f46bdb69bdaf -->|defined in| 8b44d2a6_6c89_4ea1_b8c7_64e60123bbbe
  792ae3d8_8499_60c2_cf08_c723693f4e67["_atransform()"]
  792ae3d8_8499_60c2_cf08_c723693f4e67 -->|calls| 07dae0e0_e299_4a3b_4925_f46bdb69bdaf
  3a36dbf6_6c2b_7362_1ddb_d7fe56086df3["_pick()"]
  07dae0e0_e299_4a3b_4925_f46bdb69bdaf -->|calls| 3a36dbf6_6c2b_7362_1ddb_d7fe56086df3
  792ae3d8_8499_60c2_cf08_c723693f4e67["_atransform()"]
  07dae0e0_e299_4a3b_4925_f46bdb69bdaf -->|calls| 792ae3d8_8499_60c2_cf08_c723693f4e67
  style 07dae0e0_e299_4a3b_4925_f46bdb69bdaf fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/runnables/passthrough.py lines 800–807

    async def _atransform(
        self,
        chunks: AsyncIterator[dict[str, Any]],
    ) -> AsyncIterator[Any]:
        async for chunk in chunks:
            picked = self._pick(chunk)
            if picked is not None:
                yield picked