fix(core): update task prompt, and add overflow section

Author: gusye1234

src/server/core/acontext_core/llm/prompt/task.py

@@ -42,6 +42,7 @@ def system_prompt(cls) -> str:
 - Infer execution order and insert tasks sequentially, make sure you arrange the tasks in logical execution order, no the mentioned order.
 - Ensure no task overlap, make sure the tasks are MECE(mutually exclusive, collectively exhaustive).
 - When valid new tasks mentioned, always try to capture them all, not only the first one.
+- When user asked for tasks modification and agent confirmed, make sure you will create new tasks or modify existing tasks using `update_task` tool.
 
 ### Task Assignment  
 - Match agent responses/actions to existing task descriptions and contexts
@@ -56,8 +57,7 @@ def system_prompt(cls) -> str:
 - `failed`: When explicit errors occur or tasks are abandoned
 - `pending`: For tasks not yet started
 #### Description Updates
-- Only when the user explicitly mention current task's purpose, update the task description if any changes.
-
+- When user asked for existing tasks modification and agent confirmed, make sure you will modify existing tasks' descriptions using `update_task` tool.
 
 ## Input Format
 - Input will be markdown-formatted text, with the following sections:
@@ -69,7 +69,7 @@ def system_prompt(cls) -> str:
 ## Report your thinking before calling tools
 - Use extremely brief sentences to state the plans & tasks conversation mentioned, if any.
 - Use one-two sentences to briefly describe your plan.
-- At the end, confirm you can call finish tool and call it at the end of your actions.
+- Make sure you will call tools based on your thinking, and sync with the current conversation.
 
 ## Action Guidelines
 - Be precise, context-aware, and conservative. 

src/server/core/acontext_core/llm/tool/task_lib/update.py

@@ -64,7 +64,7 @@ async def update_task_handler(
                         "task_status": {
                             "type": "string",
                             "enum": ["pending", "running", "success", "failed"],
-                            "description": "New status for the task. Use 'pending' for not started, 'running' for in progress, 'success' for completed, 'failed' for encountered errors.",
+                            "description": "New status for the task. (optional).",
                         },
                         "task_description": {
                             "type": "string",

src/server/core/acontext_core/schema/config.py

@@ -7,7 +7,7 @@
 class ProjectConfig(BaseModel):
     project_session_message_use_previous_messages_turns: int = 3
     project_session_message_buffer_max_turns: int = 6
-    project_session_message_buffer_max_overflow_turns: int = 18
+    project_session_message_buffer_max_overflow: int = 12
     project_session_message_buffer_ttl_seconds: int = 10
 
 

src/server/core/acontext_core/service/controller/message.py

@@ -18,7 +18,10 @@ async def process_session_pending_message(
             r = await MD.get_message_ids(
                 session,
                 session_id,
-                limit=project_config.project_session_message_buffer_max_overflow_turns,
+                limit=(
+                    project_config.project_session_message_buffer_max_overflow
+                    + project_config.project_session_message_buffer_max_turns
+                ),
                 asc=True,
             )
             pending_message_ids, eil = r.unpack()

src/server/core/acontext_core/service/session_message.py

@@ -97,7 +97,7 @@ async def insert_new_message(body: InsertNewMessage, message: Message):
 
     _l = await check_session_message_lock_or_set(str(body.session_id))
     if not _l:
-        LOG.info(
+        LOG.debug(
             f"Current Session is locked. "
             f"wait {DEFAULT_CORE_CONFIG.session_message_session_lock_wait_seconds} seconds for next resend. "
             f"Message {body.message_id}"
@@ -113,14 +113,14 @@ async def insert_new_message(body: InsertNewMessage, message: Message):
         LOG.info(
             f"Session message buffer is full (size: {pending_message_length}), start process"
         )
-        if (
-            pending_message_length
-            > project_config.project_session_message_buffer_max_overflow_turns
+        if pending_message_length > (
+            project_config.project_session_message_buffer_max_overflow
+            + project_config.project_session_message_buffer_max_turns
         ):
             LOG.info(
                 f"Session message buffer is overflow "
-                f"(size: {pending_message_length} > {project_config.project_session_message_buffer_max_overflow_turns}), "
-                f"Truncate the buffer, the rest will be processed later in {DEFAULT_CORE_CONFIG.session_message_session_lock_wait_seconds} seconds"
+                f"(size: {pending_message_length} > {project_config.project_session_message_buffer_max_overflow} + {project_config.project_session_message_buffer_max_turns}), "
+                f"Truncate the buffer, the rest will be re-inserted in {DEFAULT_CORE_CONFIG.session_message_session_lock_wait_seconds} seconds"
             )
             await MQ_CLIENT.publish(
                 exchange_name=EX.session_message,