chore: some tiny error

Author: Ethereal-O

vermeer/apps/master/bl/scheduler_bl.go

@@ -19,6 +19,7 @@ package bl
 
 import (
 	"errors"
+	"fmt"
 	"strconv"
 	"time"
 	"vermeer/apps/common"
@@ -201,7 +202,9 @@ func (s *ScheduleBl) tryScheduleInner(softSchedule bool, noLock ...bool) error {
 		case s.startChan <- task:
 			logrus.Infof("task '%d' sent to start channel", task.ID)
 		default:
-			logrus.Warnf("start channel is full, task '%d' could not be sent", task.ID)
+			errMsg := fmt.Sprintf("start channel is full, cannot schedule task %d", task.ID)
+			logrus.Errorf(errMsg)
+			taskMgr.SetError(task, errMsg)
 		}
 	}
 
@@ -368,7 +371,7 @@ func (s *ScheduleBl) ChangeWorkerStatus(workerName string, status schedules.Work
 func (s *ScheduleBl) waitingStartedTask() {
 	for taskInfo := range s.startChan {
 		if taskInfo == nil {
-			logrus.Warnf("recieved a nil task from startChan")
+			logrus.Warnf("received a nil task from startChan")
 			continue
 		}
 

vermeer/apps/master/bl/task_bl.go

@@ -20,6 +20,7 @@ package bl
 import (
 	"errors"
 	"fmt"
+	"math"
 	"sort"
 	"strconv"
 	"strings"
@@ -74,6 +75,9 @@ func (tb *TaskBl) CreateTaskInfo(
 				if p < 0 {
 					return nil, fmt.Errorf("priority should be non-negative")
 				}
+				if p > math.MaxInt32 {
+					return nil, fmt.Errorf("priority exceeds maximum value: %d", math.MaxInt32)
+				}
 				taskInfo.Priority = int32(p)
 			} else {
 				logrus.Warnf("priority convert to int32 error:%v", err)
@@ -85,7 +89,7 @@ func (tb *TaskBl) CreateTaskInfo(
 			for _, preorder := range preorderList {
 				if pid, err := strconv.ParseInt(preorder, 10, 32); err == nil {
 					if taskMgr.GetTaskByID(int32(pid)) == nil {
-						return nil, fmt.Errorf("preorder task id %d not exists", pid)
+						return nil, fmt.Errorf("preorder task with ID %d does not exist", pid)
 					}
 					taskInfo.Preorders = append(taskInfo.Preorders, int32(pid))
 				} else {

vermeer/apps/master/schedules/scheduler_task_manager.go

@@ -2,6 +2,7 @@ package schedules
 
 import (
 	"errors"
+	"vermeer/apps/common"
 	"vermeer/apps/structure"
 
 	"github.com/sirupsen/logrus"
@@ -86,6 +87,10 @@ func (t *SchedulerTaskManager) RefreshTaskToWorkerGroupMap() {
 * @Return error
  */
 func (t *SchedulerTaskManager) AddTaskStartSequence(taskID int32) error {
+	if common.GetConfig("debug_mode").(string) != "debug" {
+		logrus.Warn("TaskStartSequence called but debug features are disabled")
+		return nil
+	}
 	if _, exists := t.allTaskMap[taskID]; !exists {
 		return errors.New("task not found")
 	}
@@ -202,7 +207,7 @@ func (t *SchedulerTaskManager) GetAllTasksNotComplete() []*structure.TaskInfo {
 	return tasks
 }
 
-func (t *SchedulerTaskManager) GetAllTasksWaitng() []*structure.TaskInfo {
+func (t *SchedulerTaskManager) GetAllTasksWaiting() []*structure.TaskInfo {
 	tasks := make([]*structure.TaskInfo, 0, len(t.allTaskMap))
 	for _, task := range t.GetAllTasksNotComplete() {
 		if task.State == structure.TaskStateWaiting {