Browse Source

updated runtaskreq param

pull/439/head
tzwang 1 year ago
parent
commit
a99fc4c9bd
2 changed files with 4 additions and 17 deletions
  1. +1
    -8
      desc/schedule/pcm-schedule.api
  2. +3
    -9
      internal/types/types.go

+ 1
- 8
desc/schedule/pcm-schedule.api View File

@@ -204,6 +204,7 @@ type (
CodeDistribute {
DataName string `json:"dataName,optional"`
PackageID int64 `json:"packageID"`
Output string `json:"output"`
Clusters []*ClusterScheduled `json:"clusters"`
}

@@ -239,17 +240,9 @@ type (
// 启动任务(资源已就绪):/runTask
RunTaskReq {
TaskID int64 `json:"taskID"`
JobSetID string `json:"jobSetID"`
DataReturnInfos []*DataReturnInfo `json:"dataReturnInfos"`
ScheduledDatas []*DataScheduleResults `json:"scheduledDatas,optional"`
}

DataReturnInfo {

LocalJobID string `json:"localJobID"`
Output string `json:"output"`
}

DataScheduleResults {
DataType string `json:"dataType"`
Results []*DataScheduleResult `json:"results"`


+ 3
- 9
internal/types/types.go View File

@@ -5975,6 +5975,7 @@ type DatasetDistribute struct {
type CodeDistribute struct {
DataName string `json:"dataName,optional"`
PackageID int64 `json:"packageID"`
Output string `json:"output"`
Clusters []*ClusterScheduled `json:"clusters"`
}

@@ -6008,15 +6009,8 @@ type ScheduleData struct {
}

type RunTaskReq struct {
TaskID int64 `json:"taskID"`
JobSetID string `json:"jobSetID"`
DataReturnInfos []*DataReturnInfo `json:"dataReturnInfos"`
ScheduledDatas []*DataScheduleResults `json:"scheduledDatas,optional"`
}

type DataReturnInfo struct {
LocalJobID string `json:"localJobID"`
Output string `json:"output"`
TaskID int64 `json:"taskID"`
ScheduledDatas []*DataScheduleResults `json:"scheduledDatas,optional"`
}

type DataScheduleResults struct {


Loading…
Cancel
Save