diff --git a/pkg/cron/task.go b/pkg/cron/task.go index 30b05a2..71ac179 100644 --- a/pkg/cron/task.go +++ b/pkg/cron/task.go @@ -43,7 +43,7 @@ func InitTasks() error { } // 每2分钟执行一次标签观看次数更新任务 - // err = cm.AddTask("updateCastTagWatchCount", "0 */2 * * * *", UpdateCastTagWatchCountTask) + err = cm.AddTask("updateCastTagWatchCount", "0 */2 * * * *", UpdateCastTagWatchCountTask) cm.Start() // 启动队列消费者