diff --git a/src/job_manager.go b/src/job_manager.go index 0ceeaf4..073d3ae 100644 --- a/src/job_manager.go +++ b/src/job_manager.go @@ -55,8 +55,6 @@ func (jm *JobManager) start() { v.Set("cpu_limit", strconv.Itoa(jm.job.Tasks[i].NumberCPU)) v.Set("network", network) - fmt.Println(v.Encode()) - resp, err := doRequest("POST", "http://"+jm.resources[i].ClientHost+":8000/create", strings.NewReader(v.Encode()), "application/x-www-form-urlencoded", "") if err != nil { log.Println(err.Error()) @@ -70,8 +68,6 @@ func (jm *JobManager) start() { return } - log.Println(string(body)) - var res MsgCreate err = json.Unmarshal([]byte(string(body)), &res) if err != nil { diff --git a/src/resource_pool.go b/src/resource_pool.go index e659e05..fd59788 100644 --- a/src/resource_pool.go +++ b/src/resource_pool.go @@ -150,7 +150,6 @@ func (pool *ResourcePool) acquireNetwork() string { v := url.Values{} v.Set("name", network) resp, err := doRequest("POST", "http://yao-agent-master:8000/create", strings.NewReader(v.Encode()), "application/x-www-form-urlencoded", "") - fmt.Print(resp, err) if err != nil { log.Println(err.Error()) continue diff --git a/src/util.go b/src/util.go index 5d55b4c..7110872 100644 --- a/src/util.go +++ b/src/util.go @@ -91,15 +91,16 @@ type MsgCreate struct { } type TaskStatus struct { - Id string `json:"id"` - Name string `json:"name"` - Node string `json:"node"` - Image string `json:"image"` - ImageDigest string `json:"image_digest"` - Command string `json:"command"` - CreatedAt string `json:"created_at"` - FinishedAt string `json:"finished_at"` - Status string `json:"status"` + Id string `json:"id"` + HostName string `json:"hostname"` + Node string `json:"node"` + Image string `json:"image"` + ImageDigest string `json:"image_digest"` + Command string `json:"command"` + CreatedAt string `json:"created_at"` + FinishedAt string `json:"finished_at"` + Status string `json:"status"` + State map[string]interface{} `json:"state"` } type JobStatus struct {