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_algorithm_manager.go

@@ -1,3 +1,20 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package schedules
 
 import (

vermeer/apps/master/schedules/scheduler_cron_manager.go

@@ -1,3 +1,20 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package schedules
 
 import (

vermeer/apps/master/schedules/scheduler_resource_manager.go

@@ -1,3 +1,20 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package schedules
 
 import (

vermeer/apps/master/schedules/scheduler_task_manager.go

@@ -1,7 +1,25 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package schedules
 
 import (
 	"errors"
+	"vermeer/apps/common"
 	"vermeer/apps/structure"
 
 	"github.com/sirupsen/logrus"
@@ -86,6 +104,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 +224,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 {

vermeer/docker-compose.yaml

@@ -1,3 +1,20 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The ASF licenses this file to You under the Apache License, Version 2.0
+# (the "License"); you may not use this file except in compliance with
+# the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+
 version: '3.8'
 
 services:

vermeer/test/scheduler/batch.go

@@ -1,3 +1,20 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package scheduler
 
 import (

vermeer/test/scheduler/priority.go

@@ -1,3 +1,20 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package scheduler
 
 import (

vermeer/test/scheduler/routine.go

@@ -1,3 +1,20 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one or more
+contributor license agreements. See the NOTICE file distributed with this
+work for additional information regarding copyright ownership. The ASF
+licenses this file to You under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+License for the specific language governing permissions and limitations
+under the License.
+*/
+
 package scheduler
 
 import (