fix job scheduler

4 years ago · 86c0520076
parent 966870200b
commit 86c0520076
1 changed files with 2 additions and 1 deletions
--- a/src/modules/job/service/scheduler.go
+++ b/src/modules/job/service/scheduler.go
@ -88,8 +88,9 @@ func startTask(id int64, action *models.TaskAction) {
 		err = action.Update("pause")
 		if err != nil {
 			logger.Errorf("cannot update task[%d] action to 'pause': %v", id, err)
-			return
 		}
+
+		return
 	}

 	waitings, err := models.WaitingHostList(id)