diff --git a/go/internal/api/server.go b/go/internal/api/server.go
index 2a6fba6..170a2df 100644
--- a/go/internal/api/server.go
+++ b/go/internal/api/server.go
@@ -797,7 +797,7 @@ func NewServer() http.Handler {
 	selfoptimize.RegisterConsolidateFlow(selfoptimize.Flow)
 	// 注册真正的 consolidate 处理器：调用 ConsolidationPipeline
 	selfoptimize.Flow.Register("consolidate", func(task *selfoptimize.PipelineTask) error {
-		report, err := consolPipe.Run()
+		report, err := consolPipe.RunWithMode("full")
 		if err == nil && report != nil {
 			// 注入 consolidate 报告 → Dashboard
 			if report.Merged > 0 {
@@ -920,12 +920,16 @@ func NewServer() http.Handler {
 				go func(triggerID, action string) {
 					var err error
 					switch action {
-					case "distill", "consolidation", "backtrack":
-						// 深度整合含蒸馏质量回溯（Step 4）
-						_, err = consolPipe.Run()
-					case "merge":
-						_, err = consolPipe.RunMerge()
-					case "prune":
+				case "distill":
+					// distill 保持 cluster_only（高频触发，只做快速聚类）
+					_, err = consolPipe.Run()
+				case "consolidation", "backtrack":
+					// full 模式：含 prune + decay + 质量回溯（Step 4）
+					// 48h cooldown 保护，不会真正每分钟跑 full（cooldown 内 CanFire 仍返回 false）
+					_, err = consolPipe.RunWithMode("full")
+				case "merge":
+					_, err = consolPipe.RunMerge()
+				case "prune":
 						graphStore.Prune(0.15)
 				case "decay":
 					// 扫描所有记忆，按衰减率计算 freshness