_transform() — langchain Function Reference

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

Function python OutputParsing StreamingParsers calls 1 called by 1

Entity Profile

OutputParsing→ StreamingParsers→ _transform() — langchain Function Reference

Dependency Diagram

graph TD
  1f74e811_a1f8_f140_111a_7e0ac22ffb35["_transform()"]
  31a97691_3fec_0f65_0661_c4d496bb962f["BaseTransformOutputParser"]
  1f74e811_a1f8_f140_111a_7e0ac22ffb35 -->|defined in| 31a97691_3fec_0f65_0661_c4d496bb962f
  e9d78389_411d_b432_b3e7_9127c9ec4ca8["_transform()"]
  e9d78389_411d_b432_b3e7_9127c9ec4ca8 -->|calls| 1f74e811_a1f8_f140_111a_7e0ac22ffb35
  e9d78389_411d_b432_b3e7_9127c9ec4ca8["_transform()"]
  1f74e811_a1f8_f140_111a_7e0ac22ffb35 -->|calls| e9d78389_411d_b432_b3e7_9127c9ec4ca8
  style 1f74e811_a1f8_f140_111a_7e0ac22ffb35 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/output_parsers/transform.py lines 31–39

    def _transform(
        self,
        input: Iterator[str | BaseMessage],
    ) -> Iterator[T]:
        for chunk in input:
            if isinstance(chunk, BaseMessage):
                yield self.parse_result([ChatGeneration(message=chunk)])
            else:
                yield self.parse_result([Generation(text=chunk)])