atransform() — langchain Function Reference

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

Function python OutputParsing StreamingParsers

Entity Profile

OutputParsing→ StreamingParsers→ atransform() — langchain Function Reference

Dependency Diagram

graph TD
  be4f0d3c_fc83_cee3_c5e6_df4c2d2e2ed8["atransform()"]
  2c1f730b_c53c_9849_4d00_93e8b94fee33["BaseTransformOutputParser"]
  be4f0d3c_fc83_cee3_c5e6_df4c2d2e2ed8 -->|defined in| 2c1f730b_c53c_9849_4d00_93e8b94fee33
  style be4f0d3c_fc83_cee3_c5e6_df4c2d2e2ed8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/output_parsers/transform.py lines 77–96

    async def atransform(
        self,
        input: AsyncIterator[str | BaseMessage],
        config: RunnableConfig | None = None,
        **kwargs: Any,
    ) -> AsyncIterator[T]:
        """Async transform the input into the output format.

        Args:
            input: The input to transform.
            config: The configuration to use for the transformation.
            **kwargs: Additional keyword arguments.

        Yields:
            The transformed output.
        """
        async for chunk in self._atransform_stream_with_config(
            input, self._atransform, config, run_type="parser"
        ):
            yield chunk