#5019 解决模型文件更新后调度失败的问题

Merged
ychao_1983 merged 1 commits from V20231120.patch into V20231211_patch 4 months ago
  1. +1
    -0
      entity/container.go
  2. +1
    -0
      models/cloudbrain.go
  3. +1
    -0
      services/ai_task_service/cluster/c2net.go
  4. +1
    -0
      services/ai_task_service/container_builder/pre_model_builder.go

+ 1
- 0
entity/container.go View File

@@ -19,6 +19,7 @@ type ContainerData struct {
GetBackEndpoint string `json:"getBackEndpoint"`
S3DownloadUrl string `json:"s3DownloadUrl"`
Size int64 `json:"size"`
IsOverwrite bool `json:"isOverwrite"`
StorageType StorageType
}



+ 1
- 0
models/cloudbrain.go View File

@@ -2051,6 +2051,7 @@ type GrampusDataset struct {
ReadOnly bool `json:"readOnly"`
GetBackEndpoint string `json:"getBackEndpoint"`
Size int64 `json:"size"`
IsOverwrite bool `json:"isOverwrite"`
}

type CreateGrampusJobRequest struct {


+ 1
- 0
services/ai_task_service/cluster/c2net.go View File

@@ -247,6 +247,7 @@ func convertContainer2Grampus(d entity.ContainerData) models.GrampusDataset {
ReadOnly: d.ReadOnly,
GetBackEndpoint: d.GetBackEndpoint,
Size: d.Size,
IsOverwrite: d.IsOverwrite,
}
}



+ 1
- 0
services/ai_task_service/container_builder/pre_model_builder.go View File

@@ -104,6 +104,7 @@ func (b *PretrainModelBuilder) Build(ctx *context.CreationContext) ([]entity.Con
S3DownloadUrl: uploader.GetS3DownloadUrl(preTrainModelPath),
IsDir: false,
Size: size,
IsOverwrite: true,
}
preTrainModelEntity = append(preTrainModelEntity, modelData)
}


Loading…
Cancel
Save