_chunk_to_msg() — langchain Function Reference

Architecture documentation for the _chunk_to_msg() function in utils.py from the langchain codebase.

Function python CoreAbstractions MessageSchema called by 1

Entity Profile

CoreAbstractions→ MessageSchema→ _chunk_to_msg() — langchain Function Reference

Dependency Diagram

graph TD
  42b7cd62_fb9b_666d_1162_ef1187915080["_chunk_to_msg()"]
  0b528c80_0ce7_1c74_8932_bc433bcb03c6["utils.py"]
  42b7cd62_fb9b_666d_1162_ef1187915080 -->|defined in| 0b528c80_0ce7_1c74_8932_bc433bcb03c6
  23370d26_f8d8_9847_9d6f_8efb2a70861b["merge_message_runs()"]
  23370d26_f8d8_9847_9d6f_8efb2a70861b -->|calls| 42b7cd62_fb9b_666d_1162_ef1187915080
  style 42b7cd62_fb9b_666d_1162_ef1187915080 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

libs/core/langchain_core/messages/utils.py lines 2110–2128

def _chunk_to_msg(chunk: BaseMessageChunk) -> BaseMessage:
    if chunk.__class__ in _CHUNK_MSG_MAP:
        return _CHUNK_MSG_MAP[chunk.__class__](
            **chunk.model_dump(exclude={"type", "tool_call_chunks", "chunk_position"})
        )
    for chunk_cls, msg_cls in _CHUNK_MSG_MAP.items():
        if isinstance(chunk, chunk_cls):
            return msg_cls(
                **chunk.model_dump(
                    exclude={"type", "tool_call_chunks", "chunk_position"}
                )
            )

    msg = (
        f"Unrecognized message chunk class {chunk.__class__}. Supported classes are "
        f"{list(_CHUNK_MSG_MAP.keys())}"
    )
    msg = create_message(message=msg, error_code=ErrorCode.MESSAGE_COERCION_FAILURE)
    raise ValueError(msg)