27 lines
698 B
Go
27 lines
698 B
Go
package cron
|
|
|
|
func updateTaskStatus() {
|
|
//// 从core端获取任务信息
|
|
//httpClient := resty.New().R()
|
|
//result, err := httpClient.SetHeader("Content-Type", "application/json").
|
|
// SetQueryParam("adapterId", strconv.FormatInt(AdapterId, 10)).
|
|
// Get(CoreUrl + "/pcm/v1/core/pullTaskInfo")
|
|
//if err != nil {
|
|
// return
|
|
//}
|
|
//var resp coreClient.PullTaskInfoResp
|
|
//err = json.Unmarshal(result.Body(), &resp)
|
|
//if err != nil {
|
|
// return
|
|
//}
|
|
//if resp.HpcInfoList != nil && len(resp.HpcInfoList) != 0 {
|
|
// for _, slurmClient := range cronPCM.SlurmClients {
|
|
// job, err := slurmClient.Job(slurm.JobOptions{})
|
|
// if err != nil {
|
|
// return
|
|
// }
|
|
// job.ListDbJob()
|
|
// }
|
|
//}
|
|
}
|