binding fix
This commit is contained in:
parent
00a3951753
commit
73e87d9740
|
|
@ -627,7 +627,7 @@ func (s *DataScheduleAndBinding) normalBinding(rtx jobmgr.JobStateRunContext, jo
|
|||
if err != nil {
|
||||
return nil, cacheName, err
|
||||
}
|
||||
jsonData, err = json.Marshal(resp)
|
||||
jsonData, err = json.Marshal(resp.Data)
|
||||
if err != nil {
|
||||
return nil, cacheName, err
|
||||
}
|
||||
|
|
|
|||
|
|
@ -85,7 +85,7 @@ func (s *PCMJobCreate) Run(rtx jobmgr.JobStateRunContext, jo *jobmgr.Job) {
|
|||
if data.DataType == sch.IMAGE {
|
||||
s.task.Send(sch.TaskMessage{
|
||||
Status: sch.FailedStatus,
|
||||
Message: "image cannot schedule",
|
||||
Message: "Image cannot be scheduled",
|
||||
})
|
||||
rtx.Mgr.ChangeState(jo, FailureComplete(fmt.Errorf("missing image, cluster: %v", data.ClusterIDs)))
|
||||
return
|
||||
|
|
|
|||
|
|
@ -379,7 +379,7 @@ func (svc *AppService) appInfoHandle(appInfos []schsdk.AppInfo, param AppSubmitP
|
|||
if err != nil {
|
||||
return nil, nil, "", err
|
||||
}
|
||||
msg = fmt.Sprintf("{bindingID: %v}", bindingID)
|
||||
msg = fmt.Sprintf("{\"bindingID\": %v}", bindingID)
|
||||
}
|
||||
}
|
||||
return jobs, recordParams, msg, nil
|
||||
|
|
|
|||
Loading…
Reference in New Issue