diff --git a/src/job_manager.go b/src/job_manager.go index cf0393b..b1b297b 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -340,6 +340,9 @@ func (jm *JobManager) stop(force bool) MsgStop { log.Warn(res) return } + if res.Code != 0 { + log.Warn(res.Error) + } }(taskStatus) } diff --git a/src/main.go b/src/main.go index 7758353..5aa2328 100644 --- a/src/main.go +++ b/src/main.go @@ -145,6 +145,7 @@ func serverAPI(w http.ResponseWriter, r *http.Request) { break case "group_remove": + /* TODO: rearrange jobs to other queues */ log.Debug("group_remove") var group Group msg := MsgGroupCreate{Code: 0}