execution.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: flyteidl/admin/execution.proto

package admin

import (
	fmt "fmt"
	core "github.com/flyteorg/flyteidl/gen/pb-go/flyteidl/core"
	proto "github.com/golang/protobuf/proto"
	duration "github.com/golang/protobuf/ptypes/duration"
	timestamp "github.com/golang/protobuf/ptypes/timestamp"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

// The method by which this execution was launched.
type ExecutionMetadata_ExecutionMode int32

const (
	// The default execution mode, MANUAL implies that an execution was launched by an individual.
	ExecutionMetadata_MANUAL ExecutionMetadata_ExecutionMode = 0
	// A schedule triggered this execution launch.
	ExecutionMetadata_SCHEDULED ExecutionMetadata_ExecutionMode = 1
	// A system process was responsible for launching this execution rather an individual.
	ExecutionMetadata_SYSTEM ExecutionMetadata_ExecutionMode = 2
	// This execution was launched with identical inputs as a previous execution.
	ExecutionMetadata_RELAUNCH ExecutionMetadata_ExecutionMode = 3
	// This execution was triggered by another execution.
	ExecutionMetadata_CHILD_WORKFLOW ExecutionMetadata_ExecutionMode = 4
)

var ExecutionMetadata_ExecutionMode_name = map[int32]string{
	0: "MANUAL",
	1: "SCHEDULED",
	2: "SYSTEM",
	3: "RELAUNCH",
	4: "CHILD_WORKFLOW",
}

var ExecutionMetadata_ExecutionMode_value = map[string]int32{
	"MANUAL":         0,
	"SCHEDULED":      1,
	"SYSTEM":         2,
	"RELAUNCH":       3,
	"CHILD_WORKFLOW": 4,
}

func (x ExecutionMetadata_ExecutionMode) String() string {
	return proto.EnumName(ExecutionMetadata_ExecutionMode_name, int32(x))
}

func (ExecutionMetadata_ExecutionMode) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{10, 0}
}

// Request to launch an execution with the given project, domain and optionally name.
type ExecutionCreateRequest struct {
	// Name of the project the execution belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the execution belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	// If none is provided the system will generate a unique string.
	// +optional
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Additional fields necessary to launch the execution.
	Spec *ExecutionSpec `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	// The inputs required to start the execution. All required inputs must be
	// included in this map. If not required and not provided, defaults apply.
	Inputs               *core.LiteralMap `protobuf:"bytes,5,opt,name=inputs,proto3" json:"inputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *ExecutionCreateRequest) Reset()         { *m = ExecutionCreateRequest{} }
func (m *ExecutionCreateRequest) String() string { return proto.CompactTextString(m) }
func (*ExecutionCreateRequest) ProtoMessage()    {}
func (*ExecutionCreateRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{0}
}

func (m *ExecutionCreateRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionCreateRequest.Unmarshal(m, b)
}
func (m *ExecutionCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionCreateRequest.Marshal(b, m, deterministic)
}
func (m *ExecutionCreateRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionCreateRequest.Merge(m, src)
}
func (m *ExecutionCreateRequest) XXX_Size() int {
	return xxx_messageInfo_ExecutionCreateRequest.Size(m)
}
func (m *ExecutionCreateRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionCreateRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionCreateRequest proto.InternalMessageInfo

func (m *ExecutionCreateRequest) GetProject() string {
	if m != nil {
		return m.Project
	}
	return ""
}

func (m *ExecutionCreateRequest) GetDomain() string {
	if m != nil {
		return m.Domain
	}
	return ""
}

func (m *ExecutionCreateRequest) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *ExecutionCreateRequest) GetSpec() *ExecutionSpec {
	if m != nil {
		return m.Spec
	}
	return nil
}

func (m *ExecutionCreateRequest) GetInputs() *core.LiteralMap {
	if m != nil {
		return m.Inputs
	}
	return nil
}

// Request to relaunch the referenced execution.
type ExecutionRelaunchRequest struct {
	// Identifier of the workflow execution to relaunch.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User provided value for the relaunched execution.
	// If none is provided the system will generate a unique string.
	// +optional
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ExecutionRelaunchRequest) Reset()         { *m = ExecutionRelaunchRequest{} }
func (m *ExecutionRelaunchRequest) String() string { return proto.CompactTextString(m) }
func (*ExecutionRelaunchRequest) ProtoMessage()    {}
func (*ExecutionRelaunchRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{1}
}

func (m *ExecutionRelaunchRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionRelaunchRequest.Unmarshal(m, b)
}
func (m *ExecutionRelaunchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionRelaunchRequest.Marshal(b, m, deterministic)
}
func (m *ExecutionRelaunchRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionRelaunchRequest.Merge(m, src)
}
func (m *ExecutionRelaunchRequest) XXX_Size() int {
	return xxx_messageInfo_ExecutionRelaunchRequest.Size(m)
}
func (m *ExecutionRelaunchRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionRelaunchRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionRelaunchRequest proto.InternalMessageInfo

func (m *ExecutionRelaunchRequest) GetId() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.Id
	}
	return nil
}

func (m *ExecutionRelaunchRequest) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

// The unique identifier for a successfully created execution.
// If the name was *not* specified in the create request, this identifier will include a generated name.
type ExecutionCreateResponse struct {
	Id                   *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (m *ExecutionCreateResponse) Reset()         { *m = ExecutionCreateResponse{} }
func (m *ExecutionCreateResponse) String() string { return proto.CompactTextString(m) }
func (*ExecutionCreateResponse) ProtoMessage()    {}
func (*ExecutionCreateResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{2}
}

func (m *ExecutionCreateResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionCreateResponse.Unmarshal(m, b)
}
func (m *ExecutionCreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionCreateResponse.Marshal(b, m, deterministic)
}
func (m *ExecutionCreateResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionCreateResponse.Merge(m, src)
}
func (m *ExecutionCreateResponse) XXX_Size() int {
	return xxx_messageInfo_ExecutionCreateResponse.Size(m)
}
func (m *ExecutionCreateResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionCreateResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionCreateResponse proto.InternalMessageInfo

func (m *ExecutionCreateResponse) GetId() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.Id
	}
	return nil
}

// A message used to fetch a single workflow execution entity.
type WorkflowExecutionGetRequest struct {
	// Uniquely identifies an individual workflow execution.
	Id                   *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (m *WorkflowExecutionGetRequest) Reset()         { *m = WorkflowExecutionGetRequest{} }
func (m *WorkflowExecutionGetRequest) String() string { return proto.CompactTextString(m) }
func (*WorkflowExecutionGetRequest) ProtoMessage()    {}
func (*WorkflowExecutionGetRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{3}
}

func (m *WorkflowExecutionGetRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WorkflowExecutionGetRequest.Unmarshal(m, b)
}
func (m *WorkflowExecutionGetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WorkflowExecutionGetRequest.Marshal(b, m, deterministic)
}
func (m *WorkflowExecutionGetRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WorkflowExecutionGetRequest.Merge(m, src)
}
func (m *WorkflowExecutionGetRequest) XXX_Size() int {
	return xxx_messageInfo_WorkflowExecutionGetRequest.Size(m)
}
func (m *WorkflowExecutionGetRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_WorkflowExecutionGetRequest.DiscardUnknown(m)
}

var xxx_messageInfo_WorkflowExecutionGetRequest proto.InternalMessageInfo

func (m *WorkflowExecutionGetRequest) GetId() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.Id
	}
	return nil
}

// A workflow execution represents an instantiated workflow, including all inputs and additional
// metadata as well as computed results included state, outputs, and duration-based attributes.
// Used as a response object used in Get and List execution requests.
type Execution struct {
	// Unique identifier of the workflow execution.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-provided configuration and inputs for launching the execution.
	Spec *ExecutionSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// Execution results.
	Closure              *ExecutionClosure `protobuf:"bytes,3,opt,name=closure,proto3" json:"closure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *Execution) Reset()         { *m = Execution{} }
func (m *Execution) String() string { return proto.CompactTextString(m) }
func (*Execution) ProtoMessage()    {}
func (*Execution) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{4}
}

func (m *Execution) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_Execution.Unmarshal(m, b)
}
func (m *Execution) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_Execution.Marshal(b, m, deterministic)
}
func (m *Execution) XXX_Merge(src proto.Message) {
	xxx_messageInfo_Execution.Merge(m, src)
}
func (m *Execution) XXX_Size() int {
	return xxx_messageInfo_Execution.Size(m)
}
func (m *Execution) XXX_DiscardUnknown() {
	xxx_messageInfo_Execution.DiscardUnknown(m)
}

var xxx_messageInfo_Execution proto.InternalMessageInfo

func (m *Execution) GetId() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.Id
	}
	return nil
}

func (m *Execution) GetSpec() *ExecutionSpec {
	if m != nil {
		return m.Spec
	}
	return nil
}

func (m *Execution) GetClosure() *ExecutionClosure {
	if m != nil {
		return m.Closure
	}
	return nil
}

// Used as a response for request to list executions.
type ExecutionList struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	// In the case of multiple pages of results, the server-provided token can be used to fetch the next page
	// in a query. If there are no more results, this value will be empty.
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ExecutionList) Reset()         { *m = ExecutionList{} }
func (m *ExecutionList) String() string { return proto.CompactTextString(m) }
func (*ExecutionList) ProtoMessage()    {}
func (*ExecutionList) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{5}
}

func (m *ExecutionList) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionList.Unmarshal(m, b)
}
func (m *ExecutionList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionList.Marshal(b, m, deterministic)
}
func (m *ExecutionList) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionList.Merge(m, src)
}
func (m *ExecutionList) XXX_Size() int {
	return xxx_messageInfo_ExecutionList.Size(m)
}
func (m *ExecutionList) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionList.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionList proto.InternalMessageInfo

func (m *ExecutionList) GetExecutions() []*Execution {
	if m != nil {
		return m.Executions
	}
	return nil
}

func (m *ExecutionList) GetToken() string {
	if m != nil {
		return m.Token
	}
	return ""
}

// Input/output data can represented by actual values or a link to where values are stored
type LiteralMapBlob struct {
	// Types that are valid to be assigned to Data:
	//	*LiteralMapBlob_Values
	//	*LiteralMapBlob_Uri
	Data                 isLiteralMapBlob_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (m *LiteralMapBlob) Reset()         { *m = LiteralMapBlob{} }
func (m *LiteralMapBlob) String() string { return proto.CompactTextString(m) }
func (*LiteralMapBlob) ProtoMessage()    {}
func (*LiteralMapBlob) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{6}
}

func (m *LiteralMapBlob) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_LiteralMapBlob.Unmarshal(m, b)
}
func (m *LiteralMapBlob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_LiteralMapBlob.Marshal(b, m, deterministic)
}
func (m *LiteralMapBlob) XXX_Merge(src proto.Message) {
	xxx_messageInfo_LiteralMapBlob.Merge(m, src)
}
func (m *LiteralMapBlob) XXX_Size() int {
	return xxx_messageInfo_LiteralMapBlob.Size(m)
}
func (m *LiteralMapBlob) XXX_DiscardUnknown() {
	xxx_messageInfo_LiteralMapBlob.DiscardUnknown(m)
}

var xxx_messageInfo_LiteralMapBlob proto.InternalMessageInfo

type isLiteralMapBlob_Data interface {
	isLiteralMapBlob_Data()
}

type LiteralMapBlob_Values struct {
	Values *core.LiteralMap `protobuf:"bytes,1,opt,name=values,proto3,oneof"`
}

type LiteralMapBlob_Uri struct {
	Uri string `protobuf:"bytes,2,opt,name=uri,proto3,oneof"`
}

func (*LiteralMapBlob_Values) isLiteralMapBlob_Data() {}

func (*LiteralMapBlob_Uri) isLiteralMapBlob_Data() {}

func (m *LiteralMapBlob) GetData() isLiteralMapBlob_Data {
	if m != nil {
		return m.Data
	}
	return nil
}

func (m *LiteralMapBlob) GetValues() *core.LiteralMap {
	if x, ok := m.GetData().(*LiteralMapBlob_Values); ok {
		return x.Values
	}
	return nil
}

func (m *LiteralMapBlob) GetUri() string {
	if x, ok := m.GetData().(*LiteralMapBlob_Uri); ok {
		return x.Uri
	}
	return ""
}

// XXX_OneofWrappers is for the internal use of the proto package.
func (*LiteralMapBlob) XXX_OneofWrappers() []interface{} {
	return []interface{}{
		(*LiteralMapBlob_Values)(nil),
		(*LiteralMapBlob_Uri)(nil),
	}
}

type AbortMetadata struct {
	// In the case of a user-specified abort, this will pass along the user-supplied cause.
	Cause string `protobuf:"bytes,1,opt,name=cause,proto3" json:"cause,omitempty"`
	// Identifies the entity (if any) responsible for terminating the execution
	Principal            string   `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *AbortMetadata) Reset()         { *m = AbortMetadata{} }
func (m *AbortMetadata) String() string { return proto.CompactTextString(m) }
func (*AbortMetadata) ProtoMessage()    {}
func (*AbortMetadata) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{7}
}

func (m *AbortMetadata) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_AbortMetadata.Unmarshal(m, b)
}
func (m *AbortMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_AbortMetadata.Marshal(b, m, deterministic)
}
func (m *AbortMetadata) XXX_Merge(src proto.Message) {
	xxx_messageInfo_AbortMetadata.Merge(m, src)
}
func (m *AbortMetadata) XXX_Size() int {
	return xxx_messageInfo_AbortMetadata.Size(m)
}
func (m *AbortMetadata) XXX_DiscardUnknown() {
	xxx_messageInfo_AbortMetadata.DiscardUnknown(m)
}

var xxx_messageInfo_AbortMetadata proto.InternalMessageInfo

func (m *AbortMetadata) GetCause() string {
	if m != nil {
		return m.Cause
	}
	return ""
}

func (m *AbortMetadata) GetPrincipal() string {
	if m != nil {
		return m.Principal
	}
	return ""
}

// Encapsulates the results of the Execution
type ExecutionClosure struct {
	// A result produced by a terminated execution.
	// A pending (non-terminal) execution will not have any output result.
	//
	// Types that are valid to be assigned to OutputResult:
	//	*ExecutionClosure_Outputs
	//	*ExecutionClosure_Error
	//	*ExecutionClosure_AbortCause
	//	*ExecutionClosure_AbortMetadata
	OutputResult isExecutionClosure_OutputResult `protobuf_oneof:"output_result"`
	// Inputs computed and passed for execution.
	// computed_inputs depends on inputs in ExecutionSpec, fixed and default inputs in launch plan
	ComputedInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=computed_inputs,json=computedInputs,proto3" json:"computed_inputs,omitempty"` // Deprecated: Do not use.
	// Most recent recorded phase for the execution.
	Phase core.WorkflowExecution_Phase `protobuf:"varint,4,opt,name=phase,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phase,omitempty"`
	// Reported ime at which the execution began running.
	StartedAt *timestamp.Timestamp `protobuf:"bytes,5,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// The amount of time the execution spent running.
	Duration *duration.Duration `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Reported time at which the execution was created.
	CreatedAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Reported time at which the execution was last updated.
	UpdatedAt *timestamp.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// The notification settings to use after merging the CreateExecutionRequest and the launch plan
	// notification settings. An execution launched with notifications will always prefer that definition
	// to notifications defined statically in a launch plan.
	Notifications []*Notification `protobuf:"bytes,9,rep,name=notifications,proto3" json:"notifications,omitempty"`
	// Identifies the workflow definition for this execution.
	WorkflowId           *core.Identifier `protobuf:"bytes,11,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *ExecutionClosure) Reset()         { *m = ExecutionClosure{} }
func (m *ExecutionClosure) String() string { return proto.CompactTextString(m) }
func (*ExecutionClosure) ProtoMessage()    {}
func (*ExecutionClosure) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{8}
}

func (m *ExecutionClosure) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionClosure.Unmarshal(m, b)
}
func (m *ExecutionClosure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionClosure.Marshal(b, m, deterministic)
}
func (m *ExecutionClosure) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionClosure.Merge(m, src)
}
func (m *ExecutionClosure) XXX_Size() int {
	return xxx_messageInfo_ExecutionClosure.Size(m)
}
func (m *ExecutionClosure) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionClosure.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionClosure proto.InternalMessageInfo

type isExecutionClosure_OutputResult interface {
	isExecutionClosure_OutputResult()
}

type ExecutionClosure_Outputs struct {
	Outputs *LiteralMapBlob `protobuf:"bytes,1,opt,name=outputs,proto3,oneof"`
}

type ExecutionClosure_Error struct {
	Error *core.ExecutionError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type ExecutionClosure_AbortCause struct {
	AbortCause string `protobuf:"bytes,10,opt,name=abort_cause,json=abortCause,proto3,oneof"`
}

type ExecutionClosure_AbortMetadata struct {
	AbortMetadata *AbortMetadata `protobuf:"bytes,12,opt,name=abort_metadata,json=abortMetadata,proto3,oneof"`
}

func (*ExecutionClosure_Outputs) isExecutionClosure_OutputResult() {}

func (*ExecutionClosure_Error) isExecutionClosure_OutputResult() {}

func (*ExecutionClosure_AbortCause) isExecutionClosure_OutputResult() {}

func (*ExecutionClosure_AbortMetadata) isExecutionClosure_OutputResult() {}

func (m *ExecutionClosure) GetOutputResult() isExecutionClosure_OutputResult {
	if m != nil {
		return m.OutputResult
	}
	return nil
}

func (m *ExecutionClosure) GetOutputs() *LiteralMapBlob {
	if x, ok := m.GetOutputResult().(*ExecutionClosure_Outputs); ok {
		return x.Outputs
	}
	return nil
}

func (m *ExecutionClosure) GetError() *core.ExecutionError {
	if x, ok := m.GetOutputResult().(*ExecutionClosure_Error); ok {
		return x.Error
	}
	return nil
}

// Deprecated: Do not use.
func (m *ExecutionClosure) GetAbortCause() string {
	if x, ok := m.GetOutputResult().(*ExecutionClosure_AbortCause); ok {
		return x.AbortCause
	}
	return ""
}

func (m *ExecutionClosure) GetAbortMetadata() *AbortMetadata {
	if x, ok := m.GetOutputResult().(*ExecutionClosure_AbortMetadata); ok {
		return x.AbortMetadata
	}
	return nil
}

// Deprecated: Do not use.
func (m *ExecutionClosure) GetComputedInputs() *core.LiteralMap {
	if m != nil {
		return m.ComputedInputs
	}
	return nil
}

func (m *ExecutionClosure) GetPhase() core.WorkflowExecution_Phase {
	if m != nil {
		return m.Phase
	}
	return core.WorkflowExecution_UNDEFINED
}

func (m *ExecutionClosure) GetStartedAt() *timestamp.Timestamp {
	if m != nil {
		return m.StartedAt
	}
	return nil
}

func (m *ExecutionClosure) GetDuration() *duration.Duration {
	if m != nil {
		return m.Duration
	}
	return nil
}

func (m *ExecutionClosure) GetCreatedAt() *timestamp.Timestamp {
	if m != nil {
		return m.CreatedAt
	}
	return nil
}

func (m *ExecutionClosure) GetUpdatedAt() *timestamp.Timestamp {
	if m != nil {
		return m.UpdatedAt
	}
	return nil
}

func (m *ExecutionClosure) GetNotifications() []*Notification {
	if m != nil {
		return m.Notifications
	}
	return nil
}

func (m *ExecutionClosure) GetWorkflowId() *core.Identifier {
	if m != nil {
		return m.WorkflowId
	}
	return nil
}

// XXX_OneofWrappers is for the internal use of the proto package.
func (*ExecutionClosure) XXX_OneofWrappers() []interface{} {
	return []interface{}{
		(*ExecutionClosure_Outputs)(nil),
		(*ExecutionClosure_Error)(nil),
		(*ExecutionClosure_AbortCause)(nil),
		(*ExecutionClosure_AbortMetadata)(nil),
	}
}

// Represents system rather than user-facing metadata about an execution.
type SystemMetadata struct {
	// Which execution cluster this execution ran on.
	ExecutionCluster     string   `protobuf:"bytes,1,opt,name=execution_cluster,json=executionCluster,proto3" json:"execution_cluster,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SystemMetadata) Reset()         { *m = SystemMetadata{} }
func (m *SystemMetadata) String() string { return proto.CompactTextString(m) }
func (*SystemMetadata) ProtoMessage()    {}
func (*SystemMetadata) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{9}
}

func (m *SystemMetadata) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SystemMetadata.Unmarshal(m, b)
}
func (m *SystemMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SystemMetadata.Marshal(b, m, deterministic)
}
func (m *SystemMetadata) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SystemMetadata.Merge(m, src)
}
func (m *SystemMetadata) XXX_Size() int {
	return xxx_messageInfo_SystemMetadata.Size(m)
}
func (m *SystemMetadata) XXX_DiscardUnknown() {
	xxx_messageInfo_SystemMetadata.DiscardUnknown(m)
}

var xxx_messageInfo_SystemMetadata proto.InternalMessageInfo

func (m *SystemMetadata) GetExecutionCluster() string {
	if m != nil {
		return m.ExecutionCluster
	}
	return ""
}

// Represents attributes about an execution which are not required to launch the execution but are useful to record.
// These attributes are assigned at launch time and do not change.
type ExecutionMetadata struct {
	Mode ExecutionMetadata_ExecutionMode `protobuf:"varint,1,opt,name=mode,proto3,enum=flyteidl.admin.ExecutionMetadata_ExecutionMode" json:"mode,omitempty"`
	// Identifier of the entity that triggered this execution.
	// For systems using back-end authentication any value set here will be discarded in favor of the
	// authenticated user context.
	Principal string `protobuf:"bytes,2,opt,name=principal,proto3" json:"principal,omitempty"`
	// Indicates the "nestedness" of this execution.
	// If a user launches a workflow execution, the default nesting is 0.
	// If this execution further launches a workflow (child workflow), the nesting level is incremented by 0 => 1
	// Generally, if workflow at nesting level k launches a workflow then the child workflow will have
	// nesting = k + 1.
	Nesting uint32 `protobuf:"varint,3,opt,name=nesting,proto3" json:"nesting,omitempty"`
	// For scheduled executions, the requested time for execution for this specific schedule invocation.
	ScheduledAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	// Which subworkflow node launched this execution
	ParentNodeExecution *core.NodeExecutionIdentifier `protobuf:"bytes,5,opt,name=parent_node_execution,json=parentNodeExecution,proto3" json:"parent_node_execution,omitempty"`
	// Optional, a reference workflow execution related to this execution.
	// In the case of a relaunch, this references the original workflow execution.
	ReferenceExecution *core.WorkflowExecutionIdentifier `protobuf:"bytes,16,opt,name=reference_execution,json=referenceExecution,proto3" json:"reference_execution,omitempty"`
	// Optional, platform-specific metadata about the execution.
	// In this the future this may be gated behind an ACL or some sort of authorization.
	SystemMetadata       *SystemMetadata `protobuf:"bytes,17,opt,name=system_metadata,json=systemMetadata,proto3" json:"system_metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *ExecutionMetadata) Reset()         { *m = ExecutionMetadata{} }
func (m *ExecutionMetadata) String() string { return proto.CompactTextString(m) }
func (*ExecutionMetadata) ProtoMessage()    {}
func (*ExecutionMetadata) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{10}
}

func (m *ExecutionMetadata) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionMetadata.Unmarshal(m, b)
}
func (m *ExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionMetadata.Marshal(b, m, deterministic)
}
func (m *ExecutionMetadata) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionMetadata.Merge(m, src)
}
func (m *ExecutionMetadata) XXX_Size() int {
	return xxx_messageInfo_ExecutionMetadata.Size(m)
}
func (m *ExecutionMetadata) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionMetadata.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionMetadata proto.InternalMessageInfo

func (m *ExecutionMetadata) GetMode() ExecutionMetadata_ExecutionMode {
	if m != nil {
		return m.Mode
	}
	return ExecutionMetadata_MANUAL
}

func (m *ExecutionMetadata) GetPrincipal() string {
	if m != nil {
		return m.Principal
	}
	return ""
}

func (m *ExecutionMetadata) GetNesting() uint32 {
	if m != nil {
		return m.Nesting
	}
	return 0
}

func (m *ExecutionMetadata) GetScheduledAt() *timestamp.Timestamp {
	if m != nil {
		return m.ScheduledAt
	}
	return nil
}

func (m *ExecutionMetadata) GetParentNodeExecution() *core.NodeExecutionIdentifier {
	if m != nil {
		return m.ParentNodeExecution
	}
	return nil
}

func (m *ExecutionMetadata) GetReferenceExecution() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.ReferenceExecution
	}
	return nil
}

func (m *ExecutionMetadata) GetSystemMetadata() *SystemMetadata {
	if m != nil {
		return m.SystemMetadata
	}
	return nil
}

type NotificationList struct {
	Notifications        []*Notification `protobuf:"bytes,1,rep,name=notifications,proto3" json:"notifications,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (m *NotificationList) Reset()         { *m = NotificationList{} }
func (m *NotificationList) String() string { return proto.CompactTextString(m) }
func (*NotificationList) ProtoMessage()    {}
func (*NotificationList) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{11}
}

func (m *NotificationList) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_NotificationList.Unmarshal(m, b)
}
func (m *NotificationList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_NotificationList.Marshal(b, m, deterministic)
}
func (m *NotificationList) XXX_Merge(src proto.Message) {
	xxx_messageInfo_NotificationList.Merge(m, src)
}
func (m *NotificationList) XXX_Size() int {
	return xxx_messageInfo_NotificationList.Size(m)
}
func (m *NotificationList) XXX_DiscardUnknown() {
	xxx_messageInfo_NotificationList.DiscardUnknown(m)
}

var xxx_messageInfo_NotificationList proto.InternalMessageInfo

func (m *NotificationList) GetNotifications() []*Notification {
	if m != nil {
		return m.Notifications
	}
	return nil
}

// An ExecutionSpec encompasses all data used to launch this execution. The Spec does not change over the lifetime
// of an execution as it progresses across phase changes..
type ExecutionSpec struct {
	// Launch plan to be executed
	LaunchPlan *core.Identifier `protobuf:"bytes,1,opt,name=launch_plan,json=launchPlan,proto3" json:"launch_plan,omitempty"`
	// Input values to be passed for the execution
	Inputs *core.LiteralMap `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"` // Deprecated: Do not use.
	// Metadata for the execution
	Metadata *ExecutionMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Types that are valid to be assigned to NotificationOverrides:
	//	*ExecutionSpec_Notifications
	//	*ExecutionSpec_DisableAll
	NotificationOverrides isExecutionSpec_NotificationOverrides `protobuf_oneof:"notification_overrides"`
	// Labels to apply to the execution resource.
	Labels *Labels `protobuf:"bytes,7,opt,name=labels,proto3" json:"labels,omitempty"`
	// Annotations to apply to the execution resource.
	Annotations *Annotations `protobuf:"bytes,8,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// Optional: auth override to apply this execution.
	AuthRole *AuthRole `protobuf:"bytes,9,opt,name=auth_role,json=authRole,proto3" json:"auth_role,omitempty"` // Deprecated: Do not use.
	// Optional: security context override to apply this execution.
	SecurityContext *core.SecurityContext `protobuf:"bytes,10,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// Indicates the runtime priority of the execution.
	QualityOfService     *core.QualityOfService `protobuf:"bytes,17,opt,name=quality_of_service,json=qualityOfService,proto3" json:"quality_of_service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (m *ExecutionSpec) Reset()         { *m = ExecutionSpec{} }
func (m *ExecutionSpec) String() string { return proto.CompactTextString(m) }
func (*ExecutionSpec) ProtoMessage()    {}
func (*ExecutionSpec) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{12}
}

func (m *ExecutionSpec) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionSpec.Unmarshal(m, b)
}
func (m *ExecutionSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionSpec.Marshal(b, m, deterministic)
}
func (m *ExecutionSpec) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionSpec.Merge(m, src)
}
func (m *ExecutionSpec) XXX_Size() int {
	return xxx_messageInfo_ExecutionSpec.Size(m)
}
func (m *ExecutionSpec) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionSpec.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionSpec proto.InternalMessageInfo

func (m *ExecutionSpec) GetLaunchPlan() *core.Identifier {
	if m != nil {
		return m.LaunchPlan
	}
	return nil
}

// Deprecated: Do not use.
func (m *ExecutionSpec) GetInputs() *core.LiteralMap {
	if m != nil {
		return m.Inputs
	}
	return nil
}

func (m *ExecutionSpec) GetMetadata() *ExecutionMetadata {
	if m != nil {
		return m.Metadata
	}
	return nil
}

type isExecutionSpec_NotificationOverrides interface {
	isExecutionSpec_NotificationOverrides()
}

type ExecutionSpec_Notifications struct {
	Notifications *NotificationList `protobuf:"bytes,5,opt,name=notifications,proto3,oneof"`
}

type ExecutionSpec_DisableAll struct {
	DisableAll bool `protobuf:"varint,6,opt,name=disable_all,json=disableAll,proto3,oneof"`
}

func (*ExecutionSpec_Notifications) isExecutionSpec_NotificationOverrides() {}

func (*ExecutionSpec_DisableAll) isExecutionSpec_NotificationOverrides() {}

func (m *ExecutionSpec) GetNotificationOverrides() isExecutionSpec_NotificationOverrides {
	if m != nil {
		return m.NotificationOverrides
	}
	return nil
}

func (m *ExecutionSpec) GetNotifications() *NotificationList {
	if x, ok := m.GetNotificationOverrides().(*ExecutionSpec_Notifications); ok {
		return x.Notifications
	}
	return nil
}

func (m *ExecutionSpec) GetDisableAll() bool {
	if x, ok := m.GetNotificationOverrides().(*ExecutionSpec_DisableAll); ok {
		return x.DisableAll
	}
	return false
}

func (m *ExecutionSpec) GetLabels() *Labels {
	if m != nil {
		return m.Labels
	}
	return nil
}

func (m *ExecutionSpec) GetAnnotations() *Annotations {
	if m != nil {
		return m.Annotations
	}
	return nil
}

// Deprecated: Do not use.
func (m *ExecutionSpec) GetAuthRole() *AuthRole {
	if m != nil {
		return m.AuthRole
	}
	return nil
}

func (m *ExecutionSpec) GetSecurityContext() *core.SecurityContext {
	if m != nil {
		return m.SecurityContext
	}
	return nil
}

func (m *ExecutionSpec) GetQualityOfService() *core.QualityOfService {
	if m != nil {
		return m.QualityOfService
	}
	return nil
}

// XXX_OneofWrappers is for the internal use of the proto package.
func (*ExecutionSpec) XXX_OneofWrappers() []interface{} {
	return []interface{}{
		(*ExecutionSpec_Notifications)(nil),
		(*ExecutionSpec_DisableAll)(nil),
	}
}

// Request to terminate an in-progress execution.  This action is irreversible.
// If an execution is already terminated, this request will simply be a no-op.
// This request will fail if it references a non-existent execution.
// If the request succeeds the phase "ABORTED" will be recorded for the termination
// with the optional cause added to the output_result.
type ExecutionTerminateRequest struct {
	// Uniquely identifies the individual workflow execution to be terminated.
	Id *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Optional reason for aborting.
	Cause                string   `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ExecutionTerminateRequest) Reset()         { *m = ExecutionTerminateRequest{} }
func (m *ExecutionTerminateRequest) String() string { return proto.CompactTextString(m) }
func (*ExecutionTerminateRequest) ProtoMessage()    {}
func (*ExecutionTerminateRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{13}
}

func (m *ExecutionTerminateRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionTerminateRequest.Unmarshal(m, b)
}
func (m *ExecutionTerminateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionTerminateRequest.Marshal(b, m, deterministic)
}
func (m *ExecutionTerminateRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionTerminateRequest.Merge(m, src)
}
func (m *ExecutionTerminateRequest) XXX_Size() int {
	return xxx_messageInfo_ExecutionTerminateRequest.Size(m)
}
func (m *ExecutionTerminateRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionTerminateRequest.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionTerminateRequest proto.InternalMessageInfo

func (m *ExecutionTerminateRequest) GetId() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.Id
	}
	return nil
}

func (m *ExecutionTerminateRequest) GetCause() string {
	if m != nil {
		return m.Cause
	}
	return ""
}

type ExecutionTerminateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ExecutionTerminateResponse) Reset()         { *m = ExecutionTerminateResponse{} }
func (m *ExecutionTerminateResponse) String() string { return proto.CompactTextString(m) }
func (*ExecutionTerminateResponse) ProtoMessage()    {}
func (*ExecutionTerminateResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{14}
}

func (m *ExecutionTerminateResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ExecutionTerminateResponse.Unmarshal(m, b)
}
func (m *ExecutionTerminateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ExecutionTerminateResponse.Marshal(b, m, deterministic)
}
func (m *ExecutionTerminateResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ExecutionTerminateResponse.Merge(m, src)
}
func (m *ExecutionTerminateResponse) XXX_Size() int {
	return xxx_messageInfo_ExecutionTerminateResponse.Size(m)
}
func (m *ExecutionTerminateResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_ExecutionTerminateResponse.DiscardUnknown(m)
}

var xxx_messageInfo_ExecutionTerminateResponse proto.InternalMessageInfo

// Request structure to fetch inputs and output urls for an execution.
type WorkflowExecutionGetDataRequest struct {
	// The identifier of the execution for which to fetch inputs and outputs.
	Id                   *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (m *WorkflowExecutionGetDataRequest) Reset()         { *m = WorkflowExecutionGetDataRequest{} }
func (m *WorkflowExecutionGetDataRequest) String() string { return proto.CompactTextString(m) }
func (*WorkflowExecutionGetDataRequest) ProtoMessage()    {}
func (*WorkflowExecutionGetDataRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{15}
}

func (m *WorkflowExecutionGetDataRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WorkflowExecutionGetDataRequest.Unmarshal(m, b)
}
func (m *WorkflowExecutionGetDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WorkflowExecutionGetDataRequest.Marshal(b, m, deterministic)
}
func (m *WorkflowExecutionGetDataRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WorkflowExecutionGetDataRequest.Merge(m, src)
}
func (m *WorkflowExecutionGetDataRequest) XXX_Size() int {
	return xxx_messageInfo_WorkflowExecutionGetDataRequest.Size(m)
}
func (m *WorkflowExecutionGetDataRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_WorkflowExecutionGetDataRequest.DiscardUnknown(m)
}

var xxx_messageInfo_WorkflowExecutionGetDataRequest proto.InternalMessageInfo

func (m *WorkflowExecutionGetDataRequest) GetId() *core.WorkflowExecutionIdentifier {
	if m != nil {
		return m.Id
	}
	return nil
}

// Response structure for WorkflowExecutionGetDataRequest which contains inputs and outputs for an execution.
type WorkflowExecutionGetDataResponse struct {
	// Signed url to fetch a core.LiteralMap of execution outputs.
	Outputs *UrlBlob `protobuf:"bytes,1,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// Signed url to fetch a core.LiteralMap of execution inputs.
	Inputs *UrlBlob `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// Optional, full_inputs will only be populated if they are under a configured size threshold.
	FullInputs *core.LiteralMap `protobuf:"bytes,3,opt,name=full_inputs,json=fullInputs,proto3" json:"full_inputs,omitempty"`
	// Optional, full_outputs will only be populated if they are under a configured size threshold.
	FullOutputs          *core.LiteralMap `protobuf:"bytes,4,opt,name=full_outputs,json=fullOutputs,proto3" json:"full_outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (m *WorkflowExecutionGetDataResponse) Reset()         { *m = WorkflowExecutionGetDataResponse{} }
func (m *WorkflowExecutionGetDataResponse) String() string { return proto.CompactTextString(m) }
func (*WorkflowExecutionGetDataResponse) ProtoMessage()    {}
func (*WorkflowExecutionGetDataResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_4e2785d91b3809ec, []int{16}
}

func (m *WorkflowExecutionGetDataResponse) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_WorkflowExecutionGetDataResponse.Unmarshal(m, b)
}
func (m *WorkflowExecutionGetDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_WorkflowExecutionGetDataResponse.Marshal(b, m, deterministic)
}
func (m *WorkflowExecutionGetDataResponse) XXX_Merge(src proto.Message) {
	xxx_messageInfo_WorkflowExecutionGetDataResponse.Merge(m, src)
}
func (m *WorkflowExecutionGetDataResponse) XXX_Size() int {
	return xxx_messageInfo_WorkflowExecutionGetDataResponse.Size(m)
}
func (m *WorkflowExecutionGetDataResponse) XXX_DiscardUnknown() {
	xxx_messageInfo_WorkflowExecutionGetDataResponse.DiscardUnknown(m)
}

var xxx_messageInfo_WorkflowExecutionGetDataResponse proto.InternalMessageInfo

func (m *WorkflowExecutionGetDataResponse) GetOutputs() *UrlBlob {
	if m != nil {
		return m.Outputs
	}
	return nil
}

func (m *WorkflowExecutionGetDataResponse) GetInputs() *UrlBlob {
	if m != nil {
		return m.Inputs
	}
	return nil
}

func (m *WorkflowExecutionGetDataResponse) GetFullInputs() *core.LiteralMap {
	if m != nil {
		return m.FullInputs
	}
	return nil
}

func (m *WorkflowExecutionGetDataResponse) GetFullOutputs() *core.LiteralMap {
	if m != nil {
		return m.FullOutputs
	}
	return nil
}

func init() {
	proto.RegisterEnum("flyteidl.admin.ExecutionMetadata_ExecutionMode", ExecutionMetadata_ExecutionMode_name, ExecutionMetadata_ExecutionMode_value)
	proto.RegisterType((*ExecutionCreateRequest)(nil), "flyteidl.admin.ExecutionCreateRequest")
	proto.RegisterType((*ExecutionRelaunchRequest)(nil), "flyteidl.admin.ExecutionRelaunchRequest")
	proto.RegisterType((*ExecutionCreateResponse)(nil), "flyteidl.admin.ExecutionCreateResponse")
	proto.RegisterType((*WorkflowExecutionGetRequest)(nil), "flyteidl.admin.WorkflowExecutionGetRequest")
	proto.RegisterType((*Execution)(nil), "flyteidl.admin.Execution")
	proto.RegisterType((*ExecutionList)(nil), "flyteidl.admin.ExecutionList")
	proto.RegisterType((*LiteralMapBlob)(nil), "flyteidl.admin.LiteralMapBlob")
	proto.RegisterType((*AbortMetadata)(nil), "flyteidl.admin.AbortMetadata")
	proto.RegisterType((*ExecutionClosure)(nil), "flyteidl.admin.ExecutionClosure")
	proto.RegisterType((*SystemMetadata)(nil), "flyteidl.admin.SystemMetadata")
	proto.RegisterType((*ExecutionMetadata)(nil), "flyteidl.admin.ExecutionMetadata")
	proto.RegisterType((*NotificationList)(nil), "flyteidl.admin.NotificationList")
	proto.RegisterType((*ExecutionSpec)(nil), "flyteidl.admin.ExecutionSpec")
	proto.RegisterType((*ExecutionTerminateRequest)(nil), "flyteidl.admin.ExecutionTerminateRequest")
	proto.RegisterType((*ExecutionTerminateResponse)(nil), "flyteidl.admin.ExecutionTerminateResponse")
	proto.RegisterType((*WorkflowExecutionGetDataRequest)(nil), "flyteidl.admin.WorkflowExecutionGetDataRequest")
	proto.RegisterType((*WorkflowExecutionGetDataResponse)(nil), "flyteidl.admin.WorkflowExecutionGetDataResponse")
}

func init() { proto.RegisterFile("flyteidl/admin/execution.proto", fileDescriptor_4e2785d91b3809ec) }

var fileDescriptor_4e2785d91b3809ec = []byte{
	// 1369 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x57, 0xdd, 0x72, 0xd3, 0xc6,
	0x17, 0x8f, 0x1d, 0xdb, 0xc4, 0xc7, 0x89, 0x63, 0x96, 0xff, 0x3f, 0x88, 0x10, 0x20, 0x68, 0xa6,
	0x1d, 0xa6, 0x9d, 0xda, 0x43, 0x98, 0x4c, 0x87, 0x4c, 0x73, 0xe1, 0x38, 0x01, 0xa7, 0xcd, 0x07,
	0x5d, 0x93, 0x52, 0xe8, 0x74, 0xd4, 0xb5, 0xb4, 0x4e, 0x04, 0x2b, 0xad, 0x58, 0xad, 0xf8, 0xb8,
	0xeb, 0x33, 0xf4, 0x35, 0x7a, 0xdf, 0x27, 0xe8, 0x1b, 0xf5, 0x05, 0x3a, 0xda, 0x95, 0x64, 0x49,
	0x71, 0x1a, 0x18, 0xb8, 0xf3, 0xea, 0xfc, 0x7e, 0x67, 0xf7, 0x7c, 0x1f, 0xc3, 0xed, 0x09, 0x7b,
	0x2f, 0xa9, 0xeb, 0xb0, 0x1e, 0x71, 0x3c, 0xd7, 0xef, 0xd1, 0x77, 0xd4, 0x8e, 0xa4, 0xcb, 0xfd,
	0x6e, 0x20, 0xb8, 0xe4, 0xa8, 0x9d, 0xca, 0xbb, 0x4a, 0xbe, 0x7a, 0xb3, 0x84, 0xb7, 0xb9, 0xe7,
	0xa5, 0xe0, 0xd5, 0xb5, 0x4c, 0x68, 0x73, 0x41, 0x7b, 0xcc, 0x95, 0x54, 0x10, 0x16, 0x26, 0xd2,
	0x5b, 0x45, 0x69, 0xe9, 0xa6, 0xd5, 0xdb, 0x45, 0xb1, 0xeb, 0x50, 0x5f, 0xba, 0x13, 0x97, 0x8a,
	0xd9, 0xca, 0x43, 0x6a, 0x47, 0xc2, 0x95, 0xef, 0x53, 0xf6, 0x29, 0xe7, 0xa7, 0x8c, 0xf6, 0xd4,
	0x69, 0x1c, 0x4d, 0x7a, 0x4e, 0x24, 0x48, 0x4e, 0xfb, 0x9d, 0xb2, 0x5c, 0xba, 0x1e, 0x0d, 0x25,
	0xf1, 0x02, 0x0d, 0x30, 0xff, 0xae, 0xc0, 0xca, 0x5e, 0xfa, 0xa4, 0x81, 0xa0, 0x44, 0x52, 0x4c,
	0x5f, 0x47, 0x34, 0x94, 0xc8, 0x80, 0x2b, 0x81, 0xe0, 0x2f, 0xa9, 0x2d, 0x8d, 0xca, 0x7a, 0xe5,
	0x5e, 0x13, 0xa7, 0x47, 0xb4, 0x02, 0x0d, 0x87, 0x7b, 0xc4, 0xf5, 0x8d, 0xaa, 0x12, 0x24, 0x27,
	0x84, 0xa0, 0xe6, 0x13, 0x8f, 0x1a, 0xf3, 0xea, 0xab, 0xfa, 0x8d, 0xee, 0x43, 0x2d, 0x0c, 0xa8,
	0x6d, 0xd4, 0xd6, 0x2b, 0xf7, 0x5a, 0x1b, 0xb7, 0xba, 0x45, 0xc7, 0x76, 0xb3, 0xbb, 0x47, 0x01,
	0xb5, 0xb1, 0x82, 0xa2, 0xfb, 0xd0, 0x70, 0xfd, 0x20, 0x92, 0xa1, 0x51, 0x57, 0xa4, 0x1b, 0x53,
	0x52, 0xec, 0x83, 0xee, 0x81, 0x76, 0xf0, 0x21, 0x09, 0x70, 0x02, 0x34, 0x5f, 0x82, 0x91, 0x69,
	0xc2, 0x94, 0x91, 0xc8, 0xb7, 0xcf, 0x52, 0x3b, 0xb6, 0xa0, 0xea, 0x3a, 0xca, 0x84, 0xd6, 0xc6,
	0x57, 0x25, 0x55, 0xcf, 0xb8, 0x78, 0x35, 0x61, 0xfc, 0x6d, 0x46, 0xde, 0xcf, 0xfc, 0x8f, 0xab,
	0xae, 0x33, 0xcb, 0x22, 0xf3, 0x04, 0xae, 0x9f, 0xf3, 0x58, 0x18, 0x70, 0x3f, 0xa4, 0x9f, 0x72,
	0x95, 0xf9, 0x1c, 0x6e, 0x9e, 0x83, 0x3c, 0xa6, 0xf2, 0x33, 0x58, 0x61, 0xfe, 0x55, 0x81, 0x66,
	0x26, 0xfb, 0x24, 0x7f, 0xa4, 0xd1, 0xac, 0x7e, 0x78, 0x34, 0xb7, 0xe0, 0x8a, 0xcd, 0x78, 0x18,
	0x09, 0xed, 0xc5, 0xd6, 0xc6, 0xfa, 0x85, 0xac, 0x81, 0xc6, 0xe1, 0x94, 0x60, 0xfe, 0x06, 0x4b,
	0x99, 0xf0, 0xc0, 0x0d, 0x25, 0x7a, 0x08, 0x90, 0x15, 0x50, 0x68, 0x54, 0xd6, 0xe7, 0x8b, 0xe9,
	0x51, 0xd2, 0x87, 0x73, 0x60, 0xf4, 0x3f, 0xa8, 0x4b, 0xfe, 0x8a, 0xa6, 0x39, 0xab, 0x0f, 0x26,
	0x81, 0xf6, 0x34, 0x9d, 0x76, 0x18, 0x1f, 0xa3, 0x07, 0xd0, 0x78, 0x43, 0x58, 0x44, 0xc3, 0xc4,
	0x45, 0x17, 0x67, 0xdf, 0x70, 0x0e, 0x27, 0x50, 0x84, 0x60, 0x3e, 0x12, 0xae, 0x56, 0x3d, 0x9c,
	0xc3, 0xf1, 0x61, 0xa7, 0x01, 0x35, 0x87, 0x48, 0x62, 0x0e, 0x60, 0xa9, 0x3f, 0xe6, 0x42, 0x1e,
	0x52, 0x49, 0xe2, 0x0f, 0xf1, 0x4b, 0x6c, 0x12, 0x85, 0x34, 0x29, 0x2b, 0x7d, 0x40, 0x6b, 0xd0,
	0x0c, 0x84, 0xeb, 0xdb, 0x6e, 0x40, 0x58, 0xf2, 0xc6, 0xe9, 0x07, 0xf3, 0x9f, 0x3a, 0x74, 0xca,
	0x7e, 0x8a, 0x5d, 0xcb, 0x23, 0xa9, 0x2a, 0x45, 0xbf, 0xf5, 0x76, 0xd9, 0x15, 0x45, 0xdb, 0x86,
	0x73, 0x38, 0x25, 0xa0, 0x4d, 0xa8, 0x53, 0x21, 0xb8, 0x38, 0x1f, 0x4a, 0x65, 0x65, 0x76, 0xd7,
	0x5e, 0x0c, 0x1a, 0xce, 0x61, 0x8d, 0x46, 0x5f, 0x40, 0x8b, 0xc4, 0xc6, 0x58, 0xda, 0x02, 0x88,
	0xdf, 0xb9, 0x53, 0x35, 0x2a, 0xc3, 0x39, 0x0c, 0x4a, 0x30, 0x50, 0xc6, 0x3c, 0x82, 0xb6, 0x86,
	0x79, 0x89, 0xd1, 0xc6, 0xe2, 0xec, 0x8c, 0x29, 0x78, 0x66, 0x38, 0x87, 0x97, 0x48, 0xc1, 0x55,
	0x8f, 0x60, 0xd9, 0xe6, 0x5e, 0x10, 0x49, 0xea, 0x58, 0x49, 0x4f, 0x98, 0xbf, 0x24, 0x2a, 0xf1,
	0x6b, 0x70, 0x3b, 0x65, 0xed, 0x2b, 0x12, 0xfa, 0x0e, 0xea, 0xc1, 0x19, 0x09, 0xa9, 0x6a, 0x43,
	0xed, 0x8d, 0x2f, 0x2f, 0x4b, 0xfb, 0xee, 0x93, 0x18, 0x8d, 0x35, 0x29, 0xce, 0xba, 0x50, 0x12,
	0x11, 0x3f, 0x82, 0xc8, 0xa4, 0x29, 0xad, 0x76, 0x75, 0x6b, 0xed, 0xa6, 0xad, 0xb5, 0xfb, 0x34,
	0x6d, 0xad, 0xb8, 0x99, 0xa0, 0xfb, 0x12, 0x6d, 0xc2, 0x42, 0xda, 0x92, 0x8d, 0x46, 0xf2, 0xf2,
	0x32, 0x71, 0x37, 0x01, 0xe0, 0x0c, 0x1a, 0xdf, 0x68, 0xab, 0xd6, 0xa2, 0x6e, 0xbc, 0x72, 0xf9,
	0x8d, 0x09, 0xba, 0xaf, 0x4a, 0x24, 0x0a, 0x9c, 0x94, 0xba, 0x70, 0x39, 0x35, 0x41, 0xf7, 0x25,
	0xda, 0x81, 0x25, 0x9f, 0xc7, 0xd5, 0x6e, 0x13, 0x5d, 0x60, 0x4d, 0x55, 0x60, 0x6b, 0xe5, 0xa0,
	0x1d, 0xe5, 0x40, 0xb8, 0x48, 0x41, 0x5b, 0xd0, 0x7a, 0x9b, 0x78, 0xd3, 0x72, 0x1d, 0xa3, 0x35,
	0x33, 0x5a, 0xb9, 0xae, 0x02, 0x29, 0x7a, 0xdf, 0xd9, 0x59, 0x86, 0x25, 0x9d, 0x9e, 0x96, 0xa0,
	0x61, 0xc4, 0xa4, 0xb9, 0x0d, 0xed, 0xd1, 0xfb, 0x50, 0x52, 0x2f, 0x4b, 0x88, 0xaf, 0xe1, 0x6a,
	0x56, 0xd3, 0x96, 0xcd, 0xa2, 0x50, 0x52, 0x91, 0xd4, 0x51, 0x87, 0x4e, 0xeb, 0x43, 0x7d, 0x37,
	0xff, 0xac, 0xc1, 0xd5, 0x2c, 0xa4, 0x99, 0x8a, 0x01, 0xd4, 0x3c, 0xee, 0xe8, 0xea, 0x6b, 0x6f,
	0xf4, 0x2e, 0xec, 0x1e, 0x29, 0x21, 0xf7, 0x85, 0x3b, 0x14, 0x2b, 0xf2, 0x7f, 0x57, 0x6b, 0x3c,
	0x3a, 0x7d, 0x1a, 0x4a, 0xd7, 0x3f, 0x55, 0xe9, 0xba, 0x84, 0xd3, 0x23, 0xda, 0x86, 0xc5, 0xd0,
	0x3e, 0xa3, 0x4e, 0xc4, 0x74, 0x7c, 0x6a, 0x97, 0xc6, 0xa7, 0x95, 0xe1, 0xfb, 0x12, 0xbd, 0x80,
	0xff, 0x07, 0x44, 0x50, 0x5f, 0x5a, 0x3e, 0x77, 0xa8, 0x95, 0x59, 0x9c, 0x24, 0x65, 0x39, 0xaf,
	0x8f, 0xb8, 0x43, 0x67, 0xb5, 0xf2, 0x6b, 0x5a, 0x49, 0x41, 0x8c, 0x7e, 0x81, 0x6b, 0x82, 0x4e,
	0xa8, 0xa0, 0xbe, 0x9d, 0xd7, 0xdc, 0xf9, 0xe8, 0x41, 0x81, 0x32, 0x35, 0x53, 0xe5, 0x8f, 0x61,
	0x39, 0x54, 0x91, 0x9c, 0x76, 0x84, 0xab, 0xb3, 0x5b, 0x56, 0x31, 0xe0, 0xb8, 0x1d, 0x16, 0xce,
	0xe6, 0xcf, 0xb9, 0x91, 0x10, 0xc7, 0x03, 0x01, 0x34, 0x0e, 0xfb, 0x47, 0x27, 0xfd, 0x83, 0xce,
	0x1c, 0x5a, 0x82, 0xe6, 0x68, 0x30, 0xdc, 0xdb, 0x3d, 0x39, 0xd8, 0xdb, 0xed, 0x54, 0x62, 0xd1,
	0xe8, 0xf9, 0xe8, 0xe9, 0xde, 0x61, 0xa7, 0x8a, 0x16, 0x61, 0x01, 0xef, 0x1d, 0xf4, 0x4f, 0x8e,
	0x06, 0xc3, 0xce, 0x3c, 0x42, 0xd0, 0x1e, 0x0c, 0xf7, 0x0f, 0x76, 0xad, 0x67, 0xc7, 0xf8, 0x87,
	0x47, 0x07, 0xc7, 0xcf, 0x3a, 0x35, 0xf3, 0x27, 0xe8, 0xe4, 0x13, 0x5b, 0xcd, 0x9b, 0x73, 0x15,
	0x51, 0xf9, 0xe8, 0x8a, 0x30, 0xff, 0xa8, 0xe7, 0x9e, 0x3c, 0xd2, 0x23, 0xb1, 0xa5, 0x57, 0x14,
	0x2b, 0x60, 0xc4, 0xbf, 0x60, 0xce, 0xe4, 0x6b, 0x44, 0xa3, 0x9f, 0x30, 0xe2, 0xa3, 0xcd, 0x6c,
	0x39, 0xaa, 0x7e, 0x48, 0x23, 0x4c, 0xc0, 0x68, 0x1b, 0x16, 0x32, 0xc7, 0xeb, 0x0e, 0x7a, 0xf7,
	0xd2, 0xc4, 0xc7, 0x19, 0x05, 0x0d, 0xcb, 0x7e, 0xa8, 0xcf, 0x1e, 0xe5, 0x65, 0x07, 0xc6, 0x1d,
	0xbd, 0xd8, 0x1f, 0xee, 0x42, 0xcb, 0x71, 0x43, 0x32, 0x66, 0xd4, 0x22, 0x8c, 0xa9, 0x9e, 0xb8,
	0x10, 0x0f, 0x8f, 0xe4, 0x63, 0x9f, 0x31, 0xd4, 0x85, 0x06, 0x23, 0x63, 0xca, 0xc2, 0xa4, 0xf1,
	0xad, 0x9c, 0x9b, 0x6a, 0x4a, 0x8a, 0x13, 0x14, 0xda, 0x86, 0x16, 0xf1, 0x7d, 0x2e, 0x93, 0xa7,
	0xe9, 0x96, 0x77, 0xf3, 0xdc, 0xa4, 0x99, 0x42, 0x70, 0x1e, 0x8f, 0x1e, 0x42, 0x93, 0x44, 0xf2,
	0xcc, 0x12, 0x9c, 0x51, 0xa3, 0xa9, 0xc8, 0xc6, 0x39, 0x72, 0x24, 0xcf, 0x30, 0x67, 0x54, 0xf9,
	0x74, 0x81, 0x24, 0x27, 0xb4, 0x0f, 0x9d, 0x74, 0x21, 0xb7, 0x6c, 0xee, 0x4b, 0xfa, 0x4e, 0xaa,
	0x91, 0x58, 0x48, 0x6b, 0x15, 0x96, 0x51, 0x02, 0x1b, 0x68, 0x14, 0x5e, 0x0e, 0x8b, 0x1f, 0xd0,
	0x21, 0xa0, 0xd7, 0x11, 0x61, 0xb1, 0x26, 0x3e, 0xb1, 0x42, 0x2a, 0xde, 0xb8, 0x36, 0x4d, 0x6a,
	0xe4, 0x4e, 0x49, 0xd9, 0x8f, 0x1a, 0x78, 0x3c, 0x19, 0x69, 0x18, 0xee, 0xbc, 0x2e, 0x7d, 0xd9,
	0x31, 0x60, 0x25, 0xef, 0x77, 0x8b, 0xbf, 0xa1, 0x42, 0xb8, 0x0e, 0x0d, 0xbf, 0xaf, 0x2d, 0xd4,
	0x3a, 0x75, 0xd3, 0x83, 0x1b, 0x59, 0xbc, 0x9f, 0x52, 0xe1, 0xb9, 0x7e, 0x6e, 0xf3, 0xff, 0x94,
	0x0d, 0x31, 0x5b, 0x6e, 0xaa, 0xb9, 0xe5, 0xc6, 0x5c, 0x83, 0xd5, 0x59, 0xd7, 0xe9, 0xb5, 0xd9,
	0xfc, 0x15, 0xee, 0xcc, 0x5a, 0x7d, 0x77, 0xe3, 0x1c, 0xfc, 0x0c, 0xeb, 0xef, 0xef, 0x55, 0x58,
	0xbf, 0x58, 0x7f, 0xb2, 0xba, 0xdf, 0x2f, 0xef, 0x52, 0xd7, 0xcb, 0x39, 0x70, 0x22, 0x58, 0xbc,
	0x44, 0x4d, 0x57, 0xa8, 0x5e, 0xa9, 0x14, 0x2f, 0x64, 0xa4, 0x45, 0xb8, 0x05, 0xad, 0x49, 0xc4,
	0xd8, 0x87, 0x6e, 0x32, 0x18, 0x62, 0x74, 0xb6, 0xc1, 0x2c, 0x2a, 0x6e, 0xfa, 0xc8, 0xda, 0x65,
	0x64, 0x75, 0xd5, 0xb1, 0x46, 0xef, 0x7c, 0xfb, 0x62, 0xf3, 0xd4, 0x95, 0x67, 0xd1, 0xb8, 0x6b,
	0x73, 0xaf, 0xa7, 0x38, 0x5c, 0x9c, 0xf6, 0xb2, 0xff, 0x96, 0xa7, 0xd4, 0xef, 0x05, 0xe3, 0x6f,
	0x4e, 0x79, 0xaf, 0xf8, 0x47, 0x77, 0xdc, 0x50, 0x13, 0xe9, 0xc1, 0xbf, 0x01, 0x00, 0x00, 0xff,
	0xff, 0x42, 0x07, 0x57, 0xa1, 0x31, 0x0f, 0x00, 0x00,
}