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 3

Entity Profile

LangChainCore→ Runnables→ atransform() — langchain Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

libs/core/langchain_core/runnables/base.py lines 4363–4375

    def atransform(
        self,
        input: AsyncIterator[Input],
        config: RunnableConfig | None = None,
        **kwargs: Any,
    ) -> AsyncIterator[Output]:
        if not hasattr(self, "_atransform"):
            msg = f"{self!r} only supports sync methods."
            raise NotImplementedError(msg)

        return self._atransform_stream_with_config(
            input, self._atransform, config, defers_inputs=True, **kwargs
        )