task

type ActionOnTaskRequest struct {
	Task   *Task        `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	Action *ActionParam `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`
	// 请求会转发到的中心节点ID
	// 若非空，则覆盖grpc metadata中设置的to-tusita
	ToTusita string `protobuf:"bytes,3,opt,name=to_tusita,json=toTusita,proto3" json:"to_tusita,omitempty"`
	// contains filtered or unexported fields
}

type ActionOnTaskResponse struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

type ActionParam struct {
	Index    uint64                  `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Indexes  []uint64                `protobuf:"varint,2,rep,packed,name=indexes,proto3" json:"indexes,omitempty"`
	Type     enums.Dag_Graph_Action  `protobuf:"varint,3,opt,name=type,proto3,enum=sudo.protobuf.enums.Dag_Graph_Action" json:"type,omitempty"`
	UserType enums.Project_User_Type `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetStageOutputRequest struct {
	StageId uint64 `protobuf:"varint,1,opt,name=stage_id,json=stageId,proto3" json:"stage_id,omitempty"`
	PartyId string `protobuf:"bytes,2,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	InnerId uint64 `protobuf:"varint,3,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"`
	// 请求会转发到的中心节点ID
	// 若非空，则覆盖grpc metadata中设置的to-tusita
	ToTusita string `protobuf:"bytes,4,opt,name=to_tusita,json=toTusita,proto3" json:"to_tusita,omitempty"`
	// contains filtered or unexported fields
}

type GetStageOutputResponse struct {
	Vtables map[string]*vtable.Vtable `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetTasksRequest struct {
	Paginator        *paginator.Paginator `protobuf:"bytes,1,opt,name=paginator,proto3" json:"paginator,omitempty"`
	TaskId           uint64               `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskIds          []uint64             `protobuf:"varint,3,rep,packed,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	ProjectId        uint64               `protobuf:"varint,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	WithLatestConfig bool                 `protobuf:"varint,5,opt,name=with_latest_config,json=withLatestConfig,proto3" json:"with_latest_config,omitempty"`
	WithTaskRun      bool                 `protobuf:"varint,6,opt,name=with_task_run,json=withTaskRun,proto3" json:"with_task_run,omitempty"`
	WithJobConfig    bool                 `protobuf:"varint,7,opt,name=with_job_config,json=withJobConfig,proto3" json:"with_job_config,omitempty"`
	WithProgress     bool                 `protobuf:"varint,8,opt,name=with_progress,json=withProgress,proto3" json:"with_progress,omitempty"`
	ForCopy          bool                 `protobuf:"varint,9,opt,name=for_copy,json=forCopy,proto3" json:"for_copy,omitempty"`
	WithHidden       bool                 `protobuf:"varint,10,opt,name=with_hidden,json=withHidden,proto3" json:"with_hidden,omitempty"`
	NoVersionInfo    bool                 `protobuf:"varint,11,opt,name=no_version_info,json=noVersionInfo,proto3" json:"no_version_info,omitempty"`
	// UI Filter options
	Status        enums.Task_Status `protobuf:"varint,12,opt,name=status,proto3,enum=sudo.protobuf.enums.Task_Status" json:"status,omitempty"`
	StatusIn      []uint64          `protobuf:"varint,13,rep,packed,name=status_in,json=statusIn,proto3" json:"status_in,omitempty"`
	Priority      uint32            `protobuf:"varint,14,opt,name=priority,proto3" json:"priority,omitempty"`
	Type          enums.Job_Type    `protobuf:"varint,15,opt,name=type,proto3,enum=sudo.protobuf.enums.Job_Type" json:"type,omitempty"`
	CreateAfter   int64             `protobuf:"varint,16,opt,name=create_after,json=createAfter,proto3" json:"create_after,omitempty"`
	CreateBefore  int64             `protobuf:"varint,17,opt,name=create_before,json=createBefore,proto3" json:"create_before,omitempty"`
	OwnerPartyId  string            `protobuf:"bytes,18,opt,name=owner_party_id,json=ownerPartyId,proto3" json:"owner_party_id,omitempty"`
	OwnerUserIds  []uint64          `protobuf:"varint,19,rep,packed,name=owner_user_ids,json=ownerUserIds,proto3" json:"owner_user_ids,omitempty"`
	FuzzyText     string            `protobuf:"bytes,20,opt,name=fuzzy_text,json=fuzzyText,proto3" json:"fuzzy_text,omitempty"`
	FromPredict   bool              `protobuf:"varint,21,opt,name=from_predict,json=fromPredict,proto3" json:"from_predict,omitempty"`
	MajorVersion  uint64            `protobuf:"varint,22,opt,name=major_version,json=majorVersion,proto3" json:"major_version,omitempty"`
	MinorVersion  uint64            `protobuf:"varint,23,opt,name=minor_version,json=minorVersion,proto3" json:"minor_version,omitempty"`
	ClientPartyId string            `protobuf:"bytes,24,opt,name=client_party_id,json=clientPartyId,proto3" json:"client_party_id,omitempty"`
	Creator       string            `protobuf:"bytes,25,opt,name=creator,proto3" json:"creator,omitempty"`
	// 请求会转发到的中心节点ID
	// 若非空，则覆盖grpc metadata中设置的to-tusita
	ToTusita string `protobuf:"bytes,26,opt,name=to_tusita,json=toTusita,proto3" json:"to_tusita,omitempty"`
	// contains filtered or unexported fields
}

type GetTasksResponse struct {
	Data  []*TaskResponse `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Total int64           `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

type Graph struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// TODO：add edit-version
	// # of times the graph has been executed
	TotalRun uint64 `protobuf:"varint,2,opt,name=total_run,json=totalRun,proto3" json:"total_run,omitempty"`
	Frozen   bool   `protobuf:"varint,3,opt,name=frozen,proto3" json:"frozen,omitempty"`
	// contains filtered or unexported fields
}

type JobProgress struct {
	Ts       int64                                   `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	InnerId  uint64                                  `protobuf:"varint,2,opt,name=inner_id,json=innerId,proto3" json:"inner_id,omitempty"`
	PartyId  string                                  `protobuf:"bytes,3,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	Msg      string                                  `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	Category protobuf.UpdateProgressRequest_Category `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RequestItem struct {
	Value uint64              `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Unit  enums.Resource_Unit `protobuf:"varint,2,opt,name=unit,proto3,enum=sudo.protobuf.enums.Resource_Unit" json:"unit,omitempty"`
	// contains filtered or unexported fields
}

type Resource struct {
	Cpu    *RequestItem `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory *RequestItem `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty"`
	// contains filtered or unexported fields
}

type ResourceRequest struct {
	Resource *Resource                  `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	Mode     enums.Resource_RequestMode `protobuf:"varint,2,opt,name=mode,proto3,enum=sudo.protobuf.enums.Resource_RequestMode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

type SiteConfig struct {
	PartyId string `protobuf:"bytes,1,opt,name=party_id,json=partyId,proto3" json:"party_id,omitempty"`
	// OpParams
	Params          map[string]*structpb.Value                `` /* 153-byte string literal not displayed */
	ResourceRequest *ResourceRequest                          `protobuf:"bytes,3,opt,name=resource_request,json=resourceRequest,proto3" json:"resource_request,omitempty"`
	Inputs          map[string]*infra_adapter.FurnaceProperty `` /* 153-byte string literal not displayed */
	Outputs         map[string]*infra_adapter.FurnaceProperty `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Stage struct {

	// filled when Task.DoAction
	TaskId uint64 `protobuf:"varint,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// filled when GetTask, most likely be 0 in other cases，not persisted in config（because id is created when config is saved）
	JobId uint64 `protobuf:"varint,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// generated by front end, should be unique in task
	Index        uint64               `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	StageType    enums.Stage_Type     `protobuf:"varint,4,opt,name=stage_type,json=stageType,proto3,enum=sudo.protobuf.enums.Stage_Type" json:"stage_type,omitempty"`
	StageName    string               `protobuf:"bytes,5,opt,name=stage_name,json=stageName,proto3" json:"stage_name,omitempty"`
	Dependencies []uint64             `protobuf:"varint,6,rep,packed,name=dependencies,proto3" json:"dependencies,omitempty"`
	Status       enums.Dag_Job_Status `protobuf:"varint,7,opt,name=status,proto3,enum=sudo.protobuf.enums.Dag_Job_Status" json:"status,omitempty"`
	Progress     []*JobProgress       `protobuf:"bytes,8,rep,name=progress,proto3" json:"progress,omitempty"`
	// execution history group by job id（latest 2 executions by default）
	// listValue中的保存的类型为JobProgress
	HistoryProgress map[uint64]*structpb.ListValue `` /* 195-byte string literal not displayed */
	// stage location on canvas
	Top    float32      `protobuf:"fixed32,10,opt,name=top,proto3" json:"top,omitempty"`
	Left   float32      `protobuf:"fixed32,11,opt,name=left,proto3" json:"left,omitempty"`
	Config *StageParams `protobuf:"bytes,12,opt,name=config,proto3" json:"config,omitempty"`
	// 可能会修改的字段存到stage info里
	StartTs      int64  `protobuf:"varint,13,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	EndTs        int64  `protobuf:"varint,14,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"`
	Version      string `protobuf:"bytes,15,opt,name=version,proto3" json:"version,omitempty"`
	StageTypeStr string `protobuf:"bytes,16,opt,name=stage_type_str,json=stageTypeStr,proto3" json:"stage_type_str,omitempty"`
	// contains filtered or unexported fields
}

type StageParams struct {

	// OpParams
	SharedParams  map[string]*structpb.Value `` /* 185-byte string literal not displayed */
	ClientConfig  *SiteConfig                `protobuf:"bytes,2,opt,name=client_config,json=clientConfig,proto3" json:"client_config,omitempty"`
	ServerConfigs []*SiteConfig              `protobuf:"bytes,3,rep,name=server_configs,json=serverConfigs,proto3" json:"server_configs,omitempty"`
	// contains filtered or unexported fields
}

type Task struct {

	// TODO: change this field to be private after refactoring.
	Graph *Graph `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"`
	// TaskID
	//
	// 变更历史
	// Phase-1
	// 使用model.TaskModel（已被废弃），自增ID（未被使用），雪花TaskID（被当做"主键"使用）
	//
	// Phase-2
	// 引入无限编辑，复用之前的表, 但是使用新的ORM描述.
	// 新的描述没有ID字段，有TaskID字段，TaskID字段创建的时候始终引用GraphID（GraphID本身为graph的自增主键）
	//
	// Phase-3
	// 引入版本，TaskID需要与Graph ID解耦，与Phase-2相同，引用第一个graph的ID，不过在初次赋值后不再更改(db read only field)
	TaskId          uint64                `protobuf:"varint,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ProjectId       uint64                `protobuf:"varint,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name            string                `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Description     string                `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Status          enums.Task_Status     `protobuf:"varint,6,opt,name=status,proto3,enum=sudo.protobuf.enums.Task_Status" json:"status,omitempty"`
	OwnerParty      string                `protobuf:"bytes,7,opt,name=owner_party,json=ownerParty,proto3" json:"owner_party,omitempty"`
	OwnerUserId     uint64                `protobuf:"varint,8,opt,name=owner_user_id,json=ownerUserId,proto3" json:"owner_user_id,omitempty"`
	Type            enums.Job_Type        `protobuf:"varint,9,opt,name=type,proto3,enum=sudo.protobuf.enums.Job_Type" json:"type,omitempty"`
	Priority        uint32                `protobuf:"varint,10,opt,name=priority,proto3" json:"priority,omitempty"`
	Stages          []*Stage              `protobuf:"bytes,11,rep,name=stages,proto3" json:"stages,omitempty"`
	CreatedTs       int64                 `protobuf:"varint,12,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"`
	UpdatedTs       int64                 `protobuf:"varint,13,opt,name=updated_ts,json=updatedTs,proto3" json:"updated_ts,omitempty"`
	SubmittedTs     int64                 `protobuf:"varint,14,opt,name=submitted_ts,json=submittedTs,proto3" json:"submitted_ts,omitempty"`
	HiddenTs        int64                 `protobuf:"varint,15,opt,name=hidden_ts,json=hiddenTs,proto3" json:"hidden_ts,omitempty"`
	EndTs           int64                 `protobuf:"varint,16,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"`
	ComputeMode     enums.Job_ComputeMode `` /* 137-byte string literal not displayed */
	BeHidden        bool                  `protobuf:"varint,18,opt,name=be_hidden,json=beHidden,proto3" json:"be_hidden,omitempty"`
	HiddenUserId    uint64                `protobuf:"varint,19,opt,name=hidden_user_id,json=hiddenUserId,proto3" json:"hidden_user_id,omitempty"`
	MaxIndex        uint64                `protobuf:"varint,20,opt,name=max_index,json=maxIndex,proto3" json:"max_index,omitempty"`
	ResourceRequest *ResourceRequest      `protobuf:"bytes,21,opt,name=resource_request,json=resourceRequest,proto3" json:"resource_request,omitempty"`
	TaskIdStr       string                `protobuf:"bytes,22,opt,name=task_id_str,json=taskIdStr,proto3" json:"task_id_str,omitempty"`
	ProjectIdStr    string                `protobuf:"bytes,23,opt,name=project_id_str,json=projectIdStr,proto3" json:"project_id_str,omitempty"`
	// contains filtered or unexported fields
}

type TaskResponse struct {
	Base      *Task          `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"`
	OwnerUser *user.UserBase `protobuf:"bytes,2,opt,name=owner_user,json=ownerUser,proto3" json:"owner_user,omitempty"`
	// contains filtered or unexported fields
}