enhance: Stream mode task spliting PR767 (#791)

Author: Wendong-Fan

backend/app/service/chat_service.py

@@ -3,7 +3,7 @@
 import json
 from pathlib import Path
 import platform
-from typing import Literal
+from typing import Any, Literal
 from fastapi import Request
 from inflection import titleize
 from pydash import chain
@@ -464,7 +464,7 @@ def on_stream_text(chunk):
                             logger.warning(f"Failed to stream decomposition text: {e}")
 
                     async def run_decomposition():
-                        nonlocal camel_task
+                        nonlocal camel_task, summary_task_content
                         try:
                             sub_tasks = await asyncio.to_thread(
                                 workforce.eigent_make_sub_tasks,

backend/app/service/task.py

@@ -241,6 +241,7 @@ class ActionSkipTaskData(BaseModel):
     | ActionRemoveTaskData
     | ActionSkipTaskData
     | ActionDecomposeTextData
+    | ActionDecomposeProgressData
 )
 
 

backend/app/utils/agent.py

@@ -547,7 +547,7 @@ def agent_model(
             if k not in ["model_platform", "model_type", "api_key", "url"]
         }
     )
-    if agent_name in (Agents.task_agent):
+    if agent_name == Agents.task_agent:
         model_config["stream"] = True
 
     return ListenChatAgent(

src/components/ChatBox/ProjectSection.tsx

@@ -66,16 +66,16 @@ export const ProjectSection = React.forwardRef<HTMLDivElement, ProjectSectionPro
   const messages = task.messages || [];
 
   // Create a stable key based on messages content to prevent excessive re-renders
+  const lastMessage = messages[messages.length - 1];
   const messagesKey = React.useMemo(() => {
     // Only re-compute when message count or last message changes
-    const lastMsg = messages[messages.length - 1];
-    return `${messages.length}-${lastMsg?.id || ''}-${lastMsg?.content?.length || 0}`;
-  }, [messages.length, messages[messages.length - 1]?.id, messages[messages.length - 1]?.content?.length]);
+    return `${messages.length}-${lastMessage?.id || ''}-${lastMessage?.content?.length || 0}`;
+  }, [messages.length, lastMessage?.id, lastMessage?.content?.length]);
 
   // Memoize grouping to prevent re-creating objects on every render
   const queryGroups = React.useMemo(() => {
     return groupMessagesByQuery(messages);
-  }, [messagesKey, messages]);
+  }, [messagesKey]);
 
   return (
     <motion.div