fix bug

server/workerManager.go

@@ -170,12 +170,15 @@ func (wm *WorkerManager) doCallback(hook string, response *odysseus.TaskResponse
 func (wm *WorkerManager) manageWorker(worker *Worker) error {
 
 	log.WithField("worker", worker.uuid).Info("start manage worker")
-	initialInterval := time.Second * 4
 	tickerConf := config.GetConfig().Tickers
+
+	initialHeartBeatInterval := time.Second * 1
+	initialInterval := initialHeartBeatInterval * 2
+
 	heartBeatDuration := time.Second * time.Duration(tickerConf.HeartBeat)
 	workerCheckDuration := heartBeatDuration * 3
 
-	heartBeatTicker := time.NewTicker(heartBeatDuration)
+	heartBeatTicker := time.NewTicker(initialHeartBeatInterval)
 	defer heartBeatTicker.Stop()
 
 	workerCheckTicker := time.NewTicker(workerCheckDuration)
@@ -236,6 +239,7 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
 			hb.HeartbeatRequest = &omanager.HeartbeatRequest{
 				Timestamp: uint64(time.Now().Unix()),
 			}
+			heartBeatTicker.Reset(heartBeatDuration)
 			msg.Message = hb
 			callback = func(err error) bool {
 				log.WithField("worker", worker.uuid).Info("send hear beat to worker")