From 159dc88d15ddb250ce08b5b876776a0548fc0bc9 Mon Sep 17 00:00:00 2001 From: Newnius Date: Thu, 28 May 2020 20:16:24 +0800 Subject: [PATCH] update fair --- src/job_manager.go | 3 +++ src/main.go | 1 + 2 files changed, 4 insertions(+) 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}