feat(workflow): main 启动工作流恢复扫描

2026-08-25 17:06:15 +08:00
parent 36b10ae8e7
commit e0f7ce61a1
1 changed files with 3 additions and 0 deletions
@@ -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)