update get last task exec result

nm/task_handler.go

@@ -224,16 +224,16 @@ func (t *TaskWorker) GetAckResp(taskMsg *nodeManagerV1.PushTaskMessage) (isCanEx
 	value, ok := t.ExecTaskIdIsFinished.Load(t.lastExecTaskId)
 	if !ok {
 		log.WithField("task id", t.lastExecTaskId).Warn("task exec is not finished")
-		return
-	}
-	isSuccess := value.(bool)
-	log.WithField("isSuccess", isSuccess).Info("Task exec info")
-	if !isSuccess && !t.lastExecTaskStartTime.IsZero() {
-		lastTaskImageInfo := t.DockerOp.GetImageInfo(t.lastExecTaskImageName)
-		since := time.Since(t.lastExecTaskStartTime)
-		queueWaitTime = lastTaskImageInfo.EstimatExeTime - int64(since.Seconds())
-		if queueWaitTime < 0 {
-			queueWaitTime = lastTaskImageInfo.EstimatExeTime
+	} else {
+		isSuccess := value.(bool)
+		log.WithField("isSuccess", isSuccess).Info("Task exec info")
+		if !isSuccess && !t.lastExecTaskStartTime.IsZero() {
+			lastTaskImageInfo := t.DockerOp.GetImageInfo(t.lastExecTaskImageName)
+			since := time.Since(t.lastExecTaskStartTime)
+			queueWaitTime = lastTaskImageInfo.EstimatExeTime - int64(since.Seconds())
+			if queueWaitTime < 0 {
+				queueWaitTime = lastTaskImageInfo.EstimatExeTime
+			}
 		}
 	}
 	isCanExecute = true