core[minor]: update conversion utils to handle RemoveMessage (#23840)

libs/core/langchain_core/messages/utils.py

@@ -32,6 +32,7 @@ from langchain_core.messages.base import BaseMessage, BaseMessageChunk
 from langchain_core.messages.chat import ChatMessage, ChatMessageChunk
 from langchain_core.messages.function import FunctionMessage, FunctionMessageChunk
 from langchain_core.messages.human import HumanMessage, HumanMessageChunk
+from langchain_core.messages.modifier import RemoveMessage
 from langchain_core.messages.system import SystemMessage, SystemMessageChunk
 from langchain_core.messages.tool import ToolMessage, ToolMessageChunk
 
@@ -42,7 +43,12 @@ if TYPE_CHECKING:
     from langchain_core.runnables.base import Runnable
 
 AnyMessage = Union[
-    AIMessage, HumanMessage, ChatMessage, SystemMessage, FunctionMessage, ToolMessage
+    AIMessage,
+    HumanMessage,
+    ChatMessage,
+    SystemMessage,
+    FunctionMessage,
+    ToolMessage,
 ]
 
 
@@ -113,6 +119,8 @@ def _message_from_dict(message: dict) -> BaseMessage:
         return FunctionMessage(**message["data"])
     elif _type == "tool":
         return ToolMessage(**message["data"])
+    elif _type == "remove":
+        return RemoveMessage(**message["data"])
     elif _type == "AIMessageChunk":
         return AIMessageChunk(**message["data"])
     elif _type == "HumanMessageChunk":
@@ -214,6 +222,8 @@ def _create_message_from_message_type(
         message = FunctionMessage(content=content, **kwargs)
     elif message_type == "tool":
         message = ToolMessage(content=content, **kwargs)
+    elif message_type == "remove":
+        message = RemoveMessage(**kwargs)
     else:
         raise ValueError(
             f"Unexpected message type: {message_type}. Use one of 'human',"

libs/core/tests/unit_tests/test_messages.py

@@ -12,6 +12,7 @@ from langchain_core.messages import (
     FunctionMessageChunk,
     HumanMessage,
     HumanMessageChunk,
+    RemoveMessage,
     SystemMessage,
     ToolCall,
     ToolCallChunk,
@@ -649,6 +650,7 @@ def test_convert_to_messages() -> None:
                 ],
             },
             {"role": "tool", "tool_call_id": "tool_id", "content": "Hi!"},
+            {"role": "remove", "id": "message_to_remove", "content": ""},
         ]
     ) == [
         SystemMessage(content="You are a helpful assistant."),
@@ -668,6 +670,7 @@ def test_convert_to_messages() -> None:
             tool_calls=[ToolCall(name="greet", args={"name": "Jane"}, id="tool_id")],
         ),
         ToolMessage(tool_call_id="tool_id", content="Hi!"),
+        RemoveMessage(id="message_to_remove"),
     ]
 
     # tuples