|
|
@@ -2486,7 +2486,7 @@ func queryCloudBrainTask(start_unix int64, end_unix int64) (map[int64]int, map[s |
|
|
|
var indexTotal int64 |
|
|
|
indexTotal = 0 |
|
|
|
for { |
|
|
|
sess.Select("id,job_type,user_id,duration,train_job_duration,type").Table("cloudbrain").Unscoped().Where(cond).OrderBy("id asc").Limit(PAGE_SIZE, int(indexTotal)) |
|
|
|
sess.Select("id,job_type,user_id,duration,train_job_duration,type,compute_resource").Table("cloudbrain").Unscoped().Where(cond).OrderBy("id asc").Limit(PAGE_SIZE, int(indexTotal)) |
|
|
|
cloudTaskList := make([]*Cloudbrain, 0) |
|
|
|
sess.Find(&cloudTaskList) |
|
|
|
log.Info("query cloudbrain size=" + fmt.Sprint(len(cloudTaskList))) |
|
|
@@ -2529,9 +2529,6 @@ func queryCloudBrainTask(start_unix int64, end_unix int64) (map[int64]int, map[s |
|
|
|
} |
|
|
|
} else if cloudTaskRecord.ComputeResource == GPUResource { |
|
|
|
if cloudTaskRecord.JobType == "TRAIN" { |
|
|
|
if cloudTaskRecord.UserID == 247 { |
|
|
|
log.Info("test_2022 user has train task 1") |
|
|
|
} |
|
|
|
setMapKey("GpuTrainJob", cloudTaskRecord.UserID, 1, resultItemMap) |
|
|
|
} else { |
|
|
|
setMapKey("GpuDebugJob", cloudTaskRecord.UserID, 1, resultItemMap) |
|
|
|