fix(server): 启动时异步恢复未完成的任务
- 修改任务恢复为异步执行,避免阻塞服务启动 - 添加启动日志提示任务恢复开始 - 去除同步恢复完成日志,简化启动流程
This commit is contained in:
parent
56e298d79b
commit
5426ca76d8
|
|
@ -86,10 +86,9 @@ func main() {
|
|||
return s
|
||||
}()
|
||||
|
||||
// 启动时恢复未完成的任务
|
||||
// 启动时恢复未完成的任务(异步执行,不阻塞服务启动)
|
||||
log.Println("[服务启动] 开始恢复未完成的导出任务...")
|
||||
recoverRunningJobs(meta, marketing, marketingAuth, resellerDB, ymt)
|
||||
log.Println("[服务启动] 任务恢复完成")
|
||||
go recoverRunningJobs(meta, marketing, marketingAuth, resellerDB, ymt)
|
||||
|
||||
srv := &http.Server{Addr: addr, Handler: r, ReadTimeout: 15 * time.Second, WriteTimeout: 60 * time.Second}
|
||||
log.Println("server listening on ", addr)
|
||||
|
|
|
|||
Loading…
Reference in New Issue