From 86e33fc43a0207da6c6c3e1906a5e2ec19feb3cb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=99=AF=E9=98=B3?= <1656488874@qq.com>
Date: Tue, 8 Oct 2019 20:16:49 +0800
Subject: [PATCH] =?UTF-8?q?fix=20=E7=8A=B6=E6=80=81=E7=9A=84=E9=97=AE?=
 =?UTF-8?q?=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/services/task.go | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

diff --git a/backend/services/task.go b/backend/services/task.go
index 6b0effe6..cf0f61a8 100644
--- a/backend/services/task.go
+++ b/backend/services/task.go
@@ -164,12 +164,14 @@ func ExecuteShellCmd(cmdStr string, cwd string, t model.Task, s model.Spider) (e
 
 	// 在选择所有节点执行的时候，实际就是随机一个节点执行的，
 	cmd.SysProcAttr = &syscall.SysProcAttr{Setpgid: true}
+
 	// 异步启动进程
 	if err := cmd.Start(); err != nil {
 		log.Errorf("start spider error:{}", err.Error())
 		debug.PrintStack()
 		return err
 	}
+
 	// 保存pid到task
 	t.Pid = cmd.Process.Pid
 	if err := t.Save(); err != nil {
@@ -183,11 +185,18 @@ func ExecuteShellCmd(cmdStr string, cwd string, t model.Task, s model.Spider) (e
 		debug.PrintStack()
 
 		log.Infof("error type is  : %s", reflect.TypeOf(err).String())
-		// 发生一次也需要保存
-		//t.Error = err.Error()
-		//t.FinishTs = time.Now()
-		//t.Status = constants.StatusError
-		//_ = t.Save()
+		if exitError, ok := err.(*exec.ExitError); ok {
+			exitCode := exitError.ExitCode()
+			log.Errorf("exit error, exit code: %d", exitCode)
+			// 非kill 的错误类型
+			if exitCode != 9 {
+				// 发生一次也需要保存
+				t.Error = err.Error()
+				t.FinishTs = time.Now()
+				t.Status = constants.StatusError
+				_ = t.Save()
+			}
+		}
 		return err
 	}
 	ch <- constants.TaskFinish