From e0f7ce61a10e5d0d3c4c319aac00328f86f4d722 Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Tue, 25 Aug 2026 17:06:15 +0800
Subject: [PATCH] =?UTF-8?q?feat(workflow):=20main=20=E5=90=AF=E5=8A=A8?=
 =?UTF-8?q?=E5=B7=A5=E4=BD=9C=E6=B5=81=E6=81=A2=E5=A4=8D=E6=89=AB=E6=8F=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go | 3 +++
 1 file changed, 3 insertions(+)

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)