crontask/cron_task.go
@@ -20,7 +20,7 @@ var s *gocron.Scheduler func init() { s = gocron.NewScheduler(time.UTC) s = gocron.NewScheduler(time.Local) } func StartTask(isMaster bool) error { finishNumberTimeInterval := conf.Conf.PLC.FinishNumberTimeInterval @@ -91,6 +91,9 @@ return } for _, progress := range progressList { if progress.FinishedQuantity == 0 { continue } caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicSyncTaskProgress, conf.Conf.NsqConf.NodeId), "") err = caller.Send(progress) if err != nil {
