优化工作流代码

sdks/scheduler/models.go

@@ -13,6 +13,7 @@ const (
 	JobTypeInstance       = "Instance"
 	JobTypeFinetuning     = "Finetuning"
 	JobTypeDataPreprocess = "DataPreprocess"
+	JobTypeDataReturn     = "DataReturn"
 
 	FileInfoTypePackage   = "Package"
 	FileInfoTypeLocalFile = "LocalFile"
@@ -132,6 +133,8 @@ type PCMInferenceJobInfo struct {
 	Description  string       `json:"description"`
 	Files        JobFilesInfo `json:"files"`
 	JobResources JobResources `json:"jobResources"`
+
+	BindingName string `json:"bindingName"`
 }
 
 type AIJobInfo struct {
@@ -161,6 +164,7 @@ type BindingJobInfo struct {
 	JobInfoBase
 	Type string      `json:"type"`
 	Info DataBinding `json:"info"`
+	Name string      `json:"name"` // 临时使用
 }
 
 type DataBinding interface {
@@ -394,6 +398,16 @@ type DataReturnJobInfo struct {
 	Type             string          `json:"type"`
 	BucketID         cdssdk.BucketID `json:"bucketID"`
 	TargetLocalJobID string          `json:"targetLocalJobID"`
+	ReportMessage    []ReportMessage `json:"reportMessage"`
+}
+
+type ReportMessage struct {
+	TaskName  string    `json:"taskName"`
+	TaskID    string    `json:"taskID"`
+	Status    bool      `json:"status"`
+	Message   string    `json:"message"`
+	ClusterID ClusterID `json:"clusterID"`
+	Output    string    `json:"output"`
 }
 
 // MultiInstanceJobInfo 多实例(推理任务)