refactor(Context): remove finished state from flow/module context and drop MemoryUpdater finish guard

This commit is contained in:
2026-03-08 11:47:44 +08:00
parent 25ddc6f181
commit 4484d4a06b
3 changed files with 0 additions and 11 deletions

View File

@@ -86,10 +86,6 @@ public class MemoryUpdater extends PostRunningAbstractAgentModuleAbstract {
@Override @Override
public void doExecute(PartnerRunningFlowContext context) { public void doExecute(PartnerRunningFlowContext context) {
if (context.getFinished()) {
log.warn("[MemoryUpdater] 流程强制结束, 不触发记忆被动更新机制");
return;
}
executor.execute(() -> { executor.execute(() -> {
// 如果token 大于阈值,则更新记忆 // 如果token 大于阈值,则更新记忆
JSONObject moduleContext = context.getModuleContext().getExtraContext(); JSONObject moduleContext = context.getModuleContext().getExtraContext();

View File

@@ -51,12 +51,6 @@ class PartnerRunningFlowContext private constructor(
val coreContext = CoreContext() val coreContext = CoreContext()
val coreResponse = JSONObject() val coreResponse = JSONObject()
var finished: Boolean
get() = moduleContext.isFinished
set(value) {
moduleContext.isFinished = value
}
fun appendPrompt(appendPromptData: AppendPromptData) = moduleContext.appendPromptData(appendPromptData) fun appendPrompt(appendPromptData: AppendPromptData) = moduleContext.appendPromptData(appendPromptData)
} }

View File

@@ -19,7 +19,6 @@ public class ModuleContext extends PersistableObject {
private List<AppendPromptData> appendedPrompt = new ArrayList<>(); private List<AppendPromptData> appendedPrompt = new ArrayList<>();
private JSONObject extraContext = new JSONObject(); private JSONObject extraContext = new JSONObject();
private boolean finished = false;
public void appendPromptData(AppendPromptData appendPromptData) { public void appendPromptData(AppendPromptData appendPromptData) {
this.appendedPrompt.addFirst(appendPromptData); this.appendedPrompt.addFirst(appendPromptData);