diff --git a/src/job_manager.go b/src/job_manager.go index 4b82c68..a1dc1c5 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -114,9 +114,8 @@ func (jm *JobManager) logs(taskName string) MsgLog { spider.Method = "GET" spider.URL = "http://" + jm.jobStatus.tasks[taskName].Node + ":8000/logs?id=" + jm.jobStatus.tasks[taskName].Id - task, ok := jm.jobStatus.tasks[taskName] - if !ok { - log.Warn(taskName, task) + if _, ok := jm.jobStatus.tasks[taskName]; !ok { + return MsgLog{Code: -1, Error: "Task not exist"} } err := spider.do()