_msg_to_chunk() — langchain Function Reference

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

Function python CoreAbstractions MessageSchema called by 1

Entity Profile

CoreAbstractions→ MessageSchema→ _msg_to_chunk() — langchain Function Reference

Dependency Diagram

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

Relationship Graph

Source Code

libs/core/langchain_core/messages/utils.py lines 2094–2107

def _msg_to_chunk(message: BaseMessage) -> BaseMessageChunk:
    if message.__class__ in _MSG_CHUNK_MAP:
        return _MSG_CHUNK_MAP[message.__class__](**message.model_dump(exclude={"type"}))

    for msg_cls, chunk_cls in _MSG_CHUNK_MAP.items():
        if isinstance(message, msg_cls):
            return chunk_cls(**message.model_dump(exclude={"type"}))

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