diff --git a/src/main.go b/src/main.go index 77c1769..c478a3c 100644 --- a/src/main.go +++ b/src/main.go @@ -67,6 +67,7 @@ func serverAPI(w http.ResponseWriter, r *http.Request) { job.Tasks[i].Job = job.Name } job.CreatedAt = int(time.Now().Unix()) + msgSubmit.JobName = job.Name scheduler.Schedule(job) } js, err := json.Marshal(msgSubmit) diff --git a/src/message.go b/src/message.go index 5fc1603..113d31c 100644 --- a/src/message.go +++ b/src/message.go @@ -6,8 +6,9 @@ type MsgAgentReport struct { } type MsgSubmit struct { - Code int `json:"code"` - Error string `json:"error"` + Code int `json:"code"` + Error string `json:"error"` + JobName string `json:"jobName"` } type MsgPoolStatusHistory struct {