<i2fSSKJr SSKrSSKrSSKJrJr SSKJr SSK J r J r J r J r SSKJrJrJrJrJrJrJr SSKJrJr SSKJrJrJr SS KJr SS KJ r S r!\"\\-r#S r$SS jr%\%SS.SSjj5r&\"SSS9"SS\55r'"SS\5r(SSjr)SS.SSjjr*g)) annotationsN)CallableSequence)partial) AnnotatedAnyLiteralcast) AnyMessage BaseMessageBaseMessageChunkMessageLikeRepresentation RemoveMessageconvert_to_messagesmessage_chunk_to_message) TypedDict deprecated)CONFCONFIG_KEY_SENDNS_SEP) StateGraph)LangGraphDeprecatedSinceV10) add_messages MessagesState MessageGraph__remove_all__c^SSU4SjjjnTRUl[[[[/[4U5$)Ncz>Ub Ub T"X40UD6$UcUbSU(aSOSS3n[U5e[T40UD6$)NzMMust specify non-null arguments for both 'left' and 'right'. Only received: 'leftrightz'.) ValueErrorr)rr kwargsmsgfuncs g/home/dmtnaga/Documents/work/airagagent/rag_env/lib/python3.13/site-packages/langgraph/graph/message.py _add_messages,_add_messages_wrapper.._add_messages)sb   1.v. .  !2(,f':"> S/ !4*6* *)NN)rMessages | Noner r)r"rreturnz3Messages | Callable[[Messages, Messages], Messages])__doc__r rMessages)r$r&s` r%_add_messages_wrapperr-(sZ?C + +-< +OR + < + +!LLM (H-x78- HHr()formatc Sn[U[5(dU/n[U[5(dU/n[U5Vs/sHn[[ [ U55PM nn[U5Vs/sHn[[ [ U55PM nnUH5nUR bM[[R"55UlM7 [U5HdupTUR c#[[R"55Ul[U[5(dMLUR [:XdMbUnMf UbXS-S$UR5n[U5VVs0sHuptUR U_M nnn[5n UHnURUR 5=n bS[U[5(aU R!UR 5 MSU R#UR 5 XFU 'Mt[U[5(a[%SUR S35e['U5XR 'UR)U5 M UVs/sHoDR U ;dMUPM nnUS:Xa [+U5nU$U(aSU<S3n [%U 5eU$s snfs snfs snnfs snf)aPMerges two lists of messages, updating existing messages by ID. By default, this ensures the state is "append-only", unless the new message has the same ID as an existing message. Args: left: The base list of `Messages`. right: The list of `Messages` (or single `Message`) to merge into the base list. format: The format to return messages in. If `None` then `Messages` will be returned as is. If `langchain-openai` then `Messages` will be returned as `BaseMessage` objects with their contents formatted to match OpenAI message format, meaning contents can be string, `'text'` blocks, or `'image_url'` blocks and tool responses are returned as their own `ToolMessage` objects. !!! important "Requirement" Must have `langchain-core>=0.3.11` installed to use this feature. Returns: A new list of messages with the messages from `right` merged into `left`. If a message in `right` has the same ID as a message in `left`, the message from `right` will replace the message from `left`. Example: ```python title="Basic usage" from langchain_core.messages import AIMessage, HumanMessage msgs1 = [HumanMessage(content="Hello", id="1")] msgs2 = [AIMessage(content="Hi there!", id="2")] add_messages(msgs1, msgs2) # [HumanMessage(content='Hello', id='1'), AIMessage(content='Hi there!', id='2')] ``` ```python title="Overwrite existing message" msgs1 = [HumanMessage(content="Hello", id="1")] msgs2 = [HumanMessage(content="Hello again", id="1")] add_messages(msgs1, msgs2) # [HumanMessage(content='Hello again', id='1')] ``` ```python title="Use in a StateGraph" from typing import Annotated from typing_extensions import TypedDict from langgraph.graph import StateGraph class State(TypedDict): messages: Annotated[list, add_messages] builder = StateGraph(State) builder.add_node("chatbot", lambda state: {"messages": [("assistant", "Hello")]}) builder.set_entry_point("chatbot") builder.set_finish_point("chatbot") graph = builder.compile() graph.invoke({}) # {'messages': [AIMessage(content='Hello', id=...)]} ``` ```python title="Use OpenAI message format" from typing import Annotated from typing_extensions import TypedDict from langgraph.graph import StateGraph, add_messages class State(TypedDict): messages: Annotated[list, add_messages(format="langchain-openai")] def chatbot_node(state: State) -> list: return { "messages": [ { "role": "user", "content": [ { "type": "text", "text": "Here's an image:", "cache_control": {"type": "ephemeral"}, }, { "type": "image", "source": { "type": "base64", "media_type": "image/jpeg", "data": "1234", }, }, ], }, ] } builder = StateGraph(State) builder.add_node("chatbot", chatbot_node) builder.set_entry_point("chatbot") builder.set_finish_point("chatbot") graph = builder.compile() graph.invoke({"messages": []}) # { # 'messages': [ # HumanMessage( # content=[ # {"type": "text", "text": "Here's an image:"}, # { # "type": "image_url", # "image_url": {"url": "data:image/jpeg;base64,1234"}, # }, # ], # ), # ] # } ``` Nz?Attempting to delete a message with an ID that doesn't exist ('z')zlangchain-openaizUnrecognized format=z+. Expected one of 'langchain-openai', None.) isinstancelistrrr r idstruuiduuid4 enumeraterREMOVE_ALL_MESSAGEScopysetgetadddiscardr!lenappend_format_messages) rr r.remove_all_idxmidxmergedi merged_by_id ids_to_remove existing_idxr#s r%rr;s}xN dD ! !v eT " "%T* *A !&6!:;*   %U+ +A !&6!:;+    44<tzz|$ADE" 44<tzz|$AD a ' 'ADD4G,G N # !a')**YY[F(1&(9:(9ADD!G(9L:EM (,,QTT2 2L ?!]++!!!$$'%%add+'(|$!]++ UVWVZVZU[[]^"%VL  MM!  =A44}#s#J52#J:-J?'K>Kz{MessageGraph is deprecated in langgraph 1.0.0, to be removed in 2.0.0. Please use StateGraph with a `messages` key instead.)categoryc0^\rSrSrSrSU4SjjrSrU=r$)raA StateGraph where every node receives a list of messages as input and returns one or more messages as output. MessageGraph is a subclass of StateGraph whose entire state is a single, append-only* list of messages. Each node in a MessageGraph takes a list of messages as input and returns zero or more messages as output. The `add_messages` function is used to merge the output messages from each node into the existing list of messages in the graph's state. Examples: ```pycon >>> from langgraph.graph.message import MessageGraph ... >>> builder = MessageGraph() >>> builder.add_node("chatbot", lambda state: [("assistant", "Hello!")]) >>> builder.set_entry_point("chatbot") >>> builder.set_finish_point("chatbot") >>> builder.compile().invoke([("user", "Hi there.")]) [HumanMessage(content="Hi there.", id='...'), AIMessage(content="Hello!", id='...')] ``` ```pycon >>> from langchain_core.messages import AIMessage, HumanMessage, ToolMessage >>> from langgraph.graph.message import MessageGraph ... >>> builder = MessageGraph() >>> builder.add_node( ... "chatbot", ... lambda state: [ ... AIMessage( ... content="Hello!", ... tool_calls=[{"name": "search", "id": "123", "args": {"query": "X"}}], ... ) ... ], ... ) >>> builder.add_node( ... "search", lambda state: [ToolMessage(content="Searching...", tool_call_id="123")] ... ) >>> builder.set_entry_point("chatbot") >>> builder.add_edge("chatbot", "search") >>> builder.set_finish_point("search") >>> builder.compile().invoke([HumanMessage(content="Hi there. Can you search for X?")]) {'messages': [HumanMessage(content="Hi there. Can you search for X?", id='b8b7d8f4-7f4d-4f4d-9c1d-f8b8d8f4d9c1'), AIMessage(content="Hello!", id='f4d9c1d8-8d8f-4d9c-b8b7-d8f4f4d9c1d8'), ToolMessage(content="Searching...", id='d8f4f4d9-c1d8-4f4d-b8b7-d8f4f4d9c1d8', tool_call_id="123")]} ``` c>[R"S[SS9 [TU][ [ [[45 g)Nz}MessageGraph is deprecated in LangGraph v1.0.0, to be removed in v2.0.0. Please use StateGraph with a `messages` key instead.)rI stacklevel) warningswarnrsuper__init__rr2r r)self __class__s r%rRMessageGraph.__init__&s9  L0 4 #3\#ABCr()r*None)__name__ __module__ __qualname____firstlineno__r+rR__static_attributes__ __classcell__)rTs@r%rrs ,\DDr(rc \rSrSr%S\S'Srg)ri/z)Annotated[list[AnyMessage], add_messages]messagesrVN)rXrYrZr[__annotations__r\rVr(r%rr/s77r(rr_cSSKJn [U"U55$![a& Sn[R "U5 [ U5s$f=f)Nr)convert_to_openai_messageszMust have langchain-core>=0.3.11 installed to use automatic message formatting (format='langchain-openai'). Please update your langchain-core version or remove the 'format' flag. Returning un-formatted messages.)langchain_core.messagesrbr ImportErrorrOrPr2)r_rbr#s r%r@r@3sQ IF##=h#GHH    cH~s-A A ) state_keycl^ ^ SSKJm Jn SSKJn SSKJm U"5n[S[U/555nURc [S5e[USU5(aUSnURnO:[US[5(a"[U 4S jUS55(aUSn[U 4S jW5S5=n(aFUS n[[!["US 5R%[&55U4n UR)XS S9 U(aU[*[,"X4/5 U$)zWrite a message manually to the `messages` / `messages-tuple` stream mode. Will automatically write to the channel specified in the `state_key` unless `state_key` is `None`. r)BaseCallbackHandlerBaseCallbackManager) get_config)StreamMessagesHandlerc3$# UHov M g7fNrV).0xs r% push_message..Vs=<1# UHn[UT5v M g7frlr1)rmrnrgs r%rorp^s 74Gq 1)**4Gsc3N># UHn[UT5(dMUv M g7frlrs)rmrnrjs r%rorpdsEHq 1.C DHs% %metadatalanggraph_checkpoint_nsF)dedupe)langchain_core.callbacks.basergrhlanggraph.configrilanggraph.pregel._messagesrjnextrr3r!r1handlersr2alltupler r4splitr_emitrr) messagererhriconfigmanagerr|stream_handlerru message_metargrjs @@r% push_messagerCs1 ,@ \F=17)<==Gzz122&%':;;%## F;' . .374:;4G744+&EHEt~*% $sH%>?@FFvN O   \5At _% ';&<= Nr()r$rr*z(Callable[[Messages, Messages], Messages])rr,r r,r.z"Literal['langchain-openai'] | Noner*r,)r_zSequence[BaseMessage]r*zlist[BaseMessage])rz,MessageLikeRepresentation | BaseMessageChunkrez str | Noner*r )+ __future__rr5rOcollections.abcrr functoolsrtypingrrr r rcr r r rrrrtyping_extensionsrrlanggraph._internal._constantsrrrlanggraph.graph.staterlanggraph.warningsr__all__r2r,r8r-rrrr@rrVr(r%rs " .4HH,:  ) *-F F&I& 26 t t t / t  ttn B 5D:5D 5Dp8I8 I&'- 9-- -r(