refresh supervisor state

Author: nhuang-lc

src/open_deep_research/deep_researcher.py

@@ -81,13 +81,16 @@ async def write_research_brief(state: AgentState, config: RunnableConfig)-> Comm
         goto="research_supervisor", 
         update={
             "research_brief": response.research_brief,
-            "supervisor_messages": [
-                SystemMessage(content=lead_researcher_prompt.format(
-                    date=get_today_str(),
-                    max_concurrent_research_units=configurable.max_concurrent_research_units
-                )),
-                HumanMessage(content=response.research_brief)
-            ]
+            "supervisor_messages": {
+                "type": "override",
+                "value": [
+                    SystemMessage(content=lead_researcher_prompt.format(
+                        date=get_today_str(),
+                        max_concurrent_research_units=configurable.max_concurrent_research_units
+                    )),
+                    HumanMessage(content=response.research_brief)
+                ]
+            }
         }
     )
 

src/open_deep_research/state.py

@@ -52,14 +52,14 @@ class AgentInputState(MessagesState):
     """InputState is only 'messages'"""
 
 class AgentState(MessagesState):
-    supervisor_messages: Annotated[list[MessageLikeRepresentation], operator.add]
+    supervisor_messages: Annotated[list[MessageLikeRepresentation], override_reducer]
     research_brief: Optional[str]
     raw_notes: Annotated[list[str], override_reducer] = []
     notes: Annotated[list[str], override_reducer] = []
     final_report: str
 
 class SupervisorState(TypedDict):
-    supervisor_messages: Annotated[list[MessageLikeRepresentation], operator.add]
+    supervisor_messages: Annotated[list[MessageLikeRepresentation], override_reducer]
     research_brief: str
     notes: Annotated[list[str], override_reducer] = []
     research_iterations: int = 0