_atransform() — langchain Function Reference

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

Function python OutputParsing StreamingParsers calls 1 called by 1

Entity Profile

OutputParsing→ StreamingParsers→ _atransform() — langchain Function Reference

Dependency Diagram

graph TD
  f0952f44_17b9_4d56_f470_e582f8bd3c19["_atransform()"]
  2c1f730b_c53c_9849_4d00_93e8b94fee33["BaseTransformOutputParser"]
  f0952f44_17b9_4d56_f470_e582f8bd3c19 -->|defined in| 2c1f730b_c53c_9849_4d00_93e8b94fee33
  94601f14_0265_2450_4c62_273abeb4c9cf["_atransform()"]
  94601f14_0265_2450_4c62_273abeb4c9cf -->|calls| f0952f44_17b9_4d56_f470_e582f8bd3c19
  94601f14_0265_2450_4c62_273abeb4c9cf["_atransform()"]
  f0952f44_17b9_4d56_f470_e582f8bd3c19 -->|calls| 94601f14_0265_2450_4c62_273abeb4c9cf
  style f0952f44_17b9_4d56_f470_e582f8bd3c19 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/output_parsers/transform.py lines 41–53

    async def _atransform(
        self,
        input: AsyncIterator[str | BaseMessage],
    ) -> AsyncIterator[T]:
        async for chunk in input:
            if isinstance(chunk, BaseMessage):
                yield await run_in_executor(
                    None, self.parse_result, [ChatGeneration(message=chunk)]
                )
            else:
                yield await run_in_executor(
                    None, self.parse_result, [Generation(text=chunk)]
                )