JOJO/agent-Specialization
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor(compression): 压缩注入引导语与存档不再重复附带用户最近一次输入

Browse Source 
最近一次输入本身会作为正常消息出现在上下文中，注入消息里再附一份属于重复
This commit is contained in:
JOJO 2026-08-23 17:13:02 +08:00
parent 80284f1732
commit 9d3784bd90
1 changed files with 1 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
server/deep_compression.py
View File

@ -296,12 +296,11 @@ def _build_inject_guide_message(
current_record: Dict[str, Any], current_record: Dict[str, Any],
previous_records: List[Dict[str, Any]], previous_records: List[Dict[str, Any]],
user_inputs: List[str], user_inputs: List[str],
latest_user_input: str,
runtime_state_lines: Optional[List[str]] = None, runtime_state_lines: Optional[List[str]] = None,
) -> str: ) -> str:
"""生成直接注入模式的引导语：把历次压缩总结、用户输入按顺序拼入正文。""" """生成直接注入模式的引导语：把历次压缩总结、用户输入按顺序拼入正文。"""
lines: List[str] = [ lines: List[str] = [
f"当前对话已被第{compression_index}次压缩。以下为按时间顺序汇总的用户输入、历次压缩总结以及最近一次输入，请据此继续工作。", f"当前对话已被第{compression_index}次压缩。以下为按时间顺序汇总的用户输入、历次压缩总结，请据此继续工作。",
"", "",
"用户的所有输入", "用户的所有输入",
] ]
@ -315,12 +314,6 @@ def _build_inject_guide_message(
compression_index, compression_index,
) )
lines.extend(summary_lines) lines.extend(summary_lines)
lines.append("")
lines.append("用户的最近一次输入：")
if (latest_user_input or "").strip():
lines.append(latest_user_input.strip())
else:
lines.append("（无）")
if runtime_state_lines: if runtime_state_lines:
lines.append("") lines.append("")
lines.append("当前运行时状态") lines.append("当前运行时状态")
@ -398,7 +391,6 @@ def _write_compact_file(
compression_index: int, compression_index: int,
summary_text: str, summary_text: str,
user_inputs: List[str], user_inputs: List[str],
latest_user_input: str,
previous_records: List[Dict[str, Any]], previous_records: List[Dict[str, Any]],
runtime_state_lines: Optional[List[str]] = None, runtime_state_lines: Optional[List[str]] = None,
) -> str: ) -> str:
@ -422,12 +414,6 @@ def _write_compact_file(
compression_index, compression_index,
) )
lines.extend(summary_lines) lines.extend(summary_lines)
lines.append("")
lines.append("## 用户最新的一次输入")
if (latest_user_input or "").strip():
lines.append(latest_user_input.strip())
else:
lines.append("（无）")
if runtime_state_lines: if runtime_state_lines:
lines.append("") lines.append("")
lines.append("## 当前运行时状态") lines.append("## 当前运行时状态")
@ -566,7 +552,6 @@ async def run_deep_compression(
compression_index=target_count, compression_index=target_count,
summary_text=summary_text, summary_text=summary_text,
user_inputs=user_inputs, user_inputs=user_inputs,
latest_user_input=latest_user_input,
previous_records=previous_records, previous_records=previous_records,
runtime_state_lines=runtime_state_lines, runtime_state_lines=runtime_state_lines,
) )
@ -622,7 +607,6 @@ async def run_deep_compression(
current_record=current_record, current_record=current_record,
previous_records=previous_records, previous_records=previous_records,
user_inputs=user_inputs, user_inputs=user_inputs,
latest_user_input=latest_user_input,
runtime_state_lines=runtime_state_lines, runtime_state_lines=runtime_state_lines,
) )
else: else: