diff --git a/main.go b/main.go
index 2113ee3..cbbb95e 100644
--- a/main.go
+++ b/main.go
@@ -71,6 +71,9 @@ func main() {
 		},
 	})
 
+	// 启动工作流恢复扫描（首次立即扫 + 周期扫，多节点靠 Redis 锁去重）
+	flow.StartRecoveryLoop(ctx)
+
 	// 监听退出信号，执行优雅关闭
 	sigCh := make(chan os.Signal, 1)
 	signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT)