add

models/cloudbrain.go

@@ -1060,7 +1060,9 @@ type UserImageConfig struct {
 	CreateVersion bool        `json:"create_version"`
 	Flavor        Flavor      `json:"flavor"`
 	PoolID        string      `json:"pool_id"`
-	Volumes       []Volumes   `json:"volumes"`
+	ShareAddr     string      `json:"nas_share_addr"`
+	MountPath     string      `json:"nas_mount_path"`
+	NasType       string      `json:"nas_type"`
 }
 
 type CreateTrainJobParams struct {
@@ -1081,10 +1083,12 @@ type Config struct {
 	LogUrl        string      `json:"log_url"`
 	//UserImageUrl 		string       	`json:"user_image_url"`
 	//UserCommand  		string 			`json:"user_command"`
-	CreateVersion bool      `json:"create_version"`
-	Flavor        Flavor    `json:"flavor"`
-	PoolID        string    `json:"pool_id"`
-	Volumes       []Volumes `json:"volumes"`
+	CreateVersion bool   `json:"create_version"`
+	Flavor        Flavor `json:"flavor"`
+	PoolID        string `json:"pool_id"`
+	ShareAddr     string `json:"nas_share_addr"`
+	MountPath     string `json:"nas_mount_path"`
+	NasType       string `json:"nas_type"`
 }
 
 type CreateInferenceJobParams struct {

modules/modelarts/modelarts.go

@@ -67,9 +67,9 @@ const (
 	ConfigTypeCustom  = "custom"
 	TotalVersionCount = 1
 
-	NfsID         = "c6a73891-6a19-4a6a-a2e8-0d6baa72a7c5"
-	NfsSourcePath = "192.168.0.30:/"
-	NfsDestPath   = "/cache/sfs"
+	ShareAddr = "192.168.0.30:/"
+	MountPath = "/cache/sfs"
+	NasType   = "nfs"
 )
 
 var (
@@ -377,16 +377,9 @@ func GenerateTrainJob(ctx *context.Context, req *GenerateTrainJobReq) (jobId str
 				Parameter:    req.Parameters,
 				UserImageUrl: req.UserImageUrl,
 				UserCommand:  req.UserCommand,
-				Volumes: []models.Volumes{
-					{
-						Nfs: models.Nfs{
-							ID:         NfsID,
-							SourcePath: NfsSourcePath,
-							DestPath:   NfsDestPath,
-							ReadOnly:   false,
-						},
-					},
-				},
+				ShareAddr:    ShareAddr,
+				MountPath:    MountPath,
+				NasType:      NasType,
 			},
 		})
 	} else {
@@ -407,16 +400,9 @@ func GenerateTrainJob(ctx *context.Context, req *GenerateTrainJobReq) (jobId str
 					Code: req.Spec.SourceSpecId,
 				},
 				Parameter: req.Parameters,
-				Volumes: []models.Volumes{
-					{
-						Nfs: models.Nfs{
-							ID:         NfsID,
-							SourcePath: NfsSourcePath,
-							DestPath:   NfsDestPath,
-							ReadOnly:   false,
-						},
-					},
-				},
+				ShareAddr: ShareAddr,
+				MountPath: MountPath,
+				NasType:   NasType,
 			},
 		})
 	}

modules/modelarts/resty.go

@@ -497,7 +497,7 @@ sendjob:
 	}
 
 	req, _ := json.Marshal(createJobParams)
-	log.Info("postapi json: %s", string(req))
+	log.Info("postapi json: %s", req)
 
 	if res.StatusCode() == http.StatusUnauthorized && retry < 1 {
 		retry++
@@ -543,7 +543,8 @@ func createTrainJob(createJobParams models.CreateTrainJobParams) (*models.Create
 	var result models.CreateTrainJobResult
 
 	retry := 0
-	log.Info("postapi detail", createJobParams)
+	req, _ := json.Marshal(createJobParams)
+	log.Info("postapi json: %s", req)
 
 sendjob:
 	res, err := client.R().