crontask/cron_task.go
@@ -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 {
