event

package
v1.3.16 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 31, 2023 License: Apache-2.0 Imports: 16 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var TaskExecutionMetadata_InstanceClass_name = map[int32]string{
	0: "DEFAULT",
	1: "INTERRUPTIBLE",
}
View Source 
var TaskExecutionMetadata_InstanceClass_value = map[string]int32{
	"DEFAULT":       0,
	"INTERRUPTIBLE": 1,
}

Functions

This section is empty.

Types

type DynamicWorkflowNodeMetadata added in v0.18.33 

type DynamicWorkflowNodeMetadata struct {
	// id represents the unique identifier of the workflow.
	Id *core.Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Represents the compiled representation of the embedded dynamic workflow.
	CompiledWorkflow *core.CompiledWorkflowClosure `protobuf:"bytes,2,opt,name=compiled_workflow,json=compiledWorkflow,proto3" json:"compiled_workflow,omitempty"`
	// dynamic_job_spec_uri is the location of the DynamicJobSpec proto message for this DynamicWorkflow. This is
	// required to correctly recover partially completed executions where the workflow has already been compiled.
	DynamicJobSpecUri    string   `protobuf:"bytes,3,opt,name=dynamic_job_spec_uri,json=dynamicJobSpecUri,proto3" json:"dynamic_job_spec_uri,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

For dynamic workflow nodes we send information about the dynamic workflow definition that gets generated.

func (*DynamicWorkflowNodeMetadata) Descriptor added in v0.18.33 

func (*DynamicWorkflowNodeMetadata) Descriptor() ([]byte, []int)

func (*DynamicWorkflowNodeMetadata) GetCompiledWorkflow added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) GetCompiledWorkflow() *core.CompiledWorkflowClosure

func (*DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri added in v1.2.10 

func (m *DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri() string

func (*DynamicWorkflowNodeMetadata) GetId added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) GetId() *core.Identifier

func (*DynamicWorkflowNodeMetadata) ProtoMessage added in v0.18.33 

func (*DynamicWorkflowNodeMetadata) ProtoMessage()

func (*DynamicWorkflowNodeMetadata) Reset added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) Reset()

func (*DynamicWorkflowNodeMetadata) String added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) String() string

func (*DynamicWorkflowNodeMetadata) Validate added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) Validate() error

Validate checks the field values on DynamicWorkflowNodeMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*DynamicWorkflowNodeMetadata) XXX_DiscardUnknown added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) XXX_DiscardUnknown()

func (*DynamicWorkflowNodeMetadata) XXX_Marshal added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DynamicWorkflowNodeMetadata) XXX_Merge added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) XXX_Merge(src proto.Message)

func (*DynamicWorkflowNodeMetadata) XXX_Size added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) XXX_Size() int

func (*DynamicWorkflowNodeMetadata) XXX_Unmarshal added in v0.18.33 

func (m *DynamicWorkflowNodeMetadata) XXX_Unmarshal(b []byte) error

type DynamicWorkflowNodeMetadataValidationError added in v0.18.33 

type DynamicWorkflowNodeMetadataValidationError struct {
	// contains filtered or unexported fields
}

DynamicWorkflowNodeMetadataValidationError is the validation error returned by DynamicWorkflowNodeMetadata.Validate if the designated constraints aren't met.

func (DynamicWorkflowNodeMetadataValidationError) Cause added in v0.18.33 

func (e DynamicWorkflowNodeMetadataValidationError) Cause() error

Cause function returns cause value.

func (DynamicWorkflowNodeMetadataValidationError) Error added in v0.18.33 

func (e DynamicWorkflowNodeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (DynamicWorkflowNodeMetadataValidationError) ErrorName added in v0.18.33 

func (e DynamicWorkflowNodeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (DynamicWorkflowNodeMetadataValidationError) Field added in v0.18.33 

func (e DynamicWorkflowNodeMetadataValidationError) Field() string

Field function returns field value.

func (DynamicWorkflowNodeMetadataValidationError) Key added in v0.18.33 

func (e DynamicWorkflowNodeMetadataValidationError) Key() bool

Key function returns key value.

func (DynamicWorkflowNodeMetadataValidationError) Reason added in v0.18.33 

func (e DynamicWorkflowNodeMetadataValidationError) Reason() string

Reason function returns reason value.

type ExternalResourceInfo added in v0.18.23 

type ExternalResourceInfo struct {
	// Identifier for an external resource created by this task execution, for example Qubole query ID or presto query ids.
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// A unique index for the external resource with respect to all external resources for this task. Although the
	// identifier may change between task reporting events or retries, this will remain the same to enable aggregating
	// information from multiple reports.
	Index uint32 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	// Retry attempt number for this external resource, ie., 2 for the second attempt
	RetryAttempt uint32 `protobuf:"varint,3,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	// Phase associated with the external resource
	Phase core.TaskExecution_Phase `protobuf:"varint,4,opt,name=phase,proto3,enum=flyteidl.core.TaskExecution_Phase" json:"phase,omitempty"`
	// Captures the status of caching for this external resource execution.
	CacheStatus core.CatalogCacheStatus `` /* 133-byte string literal not displayed */
	// log information for the external resource execution
	Logs                 []*core.TaskLog `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

This message contains metadata about external resources produced or used by a specific task execution.

func (*ExternalResourceInfo) Descriptor added in v0.18.23 

func (*ExternalResourceInfo) Descriptor() ([]byte, []int)

func (*ExternalResourceInfo) GetCacheStatus added in v0.24.7 

func (m *ExternalResourceInfo) GetCacheStatus() core.CatalogCacheStatus

func (*ExternalResourceInfo) GetExternalId added in v0.18.25 

func (m *ExternalResourceInfo) GetExternalId() string

func (*ExternalResourceInfo) GetIndex added in v0.21.22 

func (m *ExternalResourceInfo) GetIndex() uint32

func (*ExternalResourceInfo) GetLogs added in v0.24.7 

func (m *ExternalResourceInfo) GetLogs() []*core.TaskLog

func (*ExternalResourceInfo) GetPhase added in v0.21.22 

func (m *ExternalResourceInfo) GetPhase() core.TaskExecution_Phase

func (*ExternalResourceInfo) GetRetryAttempt added in v0.21.22 

func (m *ExternalResourceInfo) GetRetryAttempt() uint32

func (*ExternalResourceInfo) ProtoMessage added in v0.18.23 

func (*ExternalResourceInfo) ProtoMessage()

func (*ExternalResourceInfo) Reset added in v0.18.23 

func (m *ExternalResourceInfo) Reset()

func (*ExternalResourceInfo) String added in v0.18.23 

func (m *ExternalResourceInfo) String() string

func (*ExternalResourceInfo) Validate added in v0.18.23 

func (m *ExternalResourceInfo) Validate() error

Validate checks the field values on ExternalResourceInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ExternalResourceInfo) XXX_DiscardUnknown added in v0.18.23 

func (m *ExternalResourceInfo) XXX_DiscardUnknown()

func (*ExternalResourceInfo) XXX_Marshal added in v0.18.23 

func (m *ExternalResourceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExternalResourceInfo) XXX_Merge added in v0.18.23 

func (m *ExternalResourceInfo) XXX_Merge(src proto.Message)

func (*ExternalResourceInfo) XXX_Size added in v0.18.23 

func (m *ExternalResourceInfo) XXX_Size() int

func (*ExternalResourceInfo) XXX_Unmarshal added in v0.18.23 

func (m *ExternalResourceInfo) XXX_Unmarshal(b []byte) error

type ExternalResourceInfoValidationError added in v0.18.23 

type ExternalResourceInfoValidationError struct {
	// contains filtered or unexported fields
}

ExternalResourceInfoValidationError is the validation error returned by ExternalResourceInfo.Validate if the designated constraints aren't met.

func (ExternalResourceInfoValidationError) Cause added in v0.18.23 

func (e ExternalResourceInfoValidationError) Cause() error

Cause function returns cause value.

func (ExternalResourceInfoValidationError) Error added in v0.18.23 

func (e ExternalResourceInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ExternalResourceInfoValidationError) ErrorName added in v0.18.23 

func (e ExternalResourceInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ExternalResourceInfoValidationError) Field added in v0.18.23 

func (e ExternalResourceInfoValidationError) Field() string

Field function returns field value.

func (ExternalResourceInfoValidationError) Key added in v0.18.23 

func (e ExternalResourceInfoValidationError) Key() bool

Key function returns key value.

func (ExternalResourceInfoValidationError) Reason added in v0.18.23 

func (e ExternalResourceInfoValidationError) Reason() string

Reason function returns reason value.

type NodeExecutionEvent 

type NodeExecutionEvent struct {
	// Unique identifier for this node execution
	Id *core.NodeExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// the id of the originator (Propeller) of the event
	ProducerId string                   `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	Phase      core.NodeExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.NodeExecution_Phase" json:"phase,omitempty"`
	// This timestamp represents when the original event occurred, it is generated
	// by the executor of the node.
	OccurredAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are valid to be assigned to InputValue:
	//	*NodeExecutionEvent_InputUri
	//	*NodeExecutionEvent_InputData
	InputValue isNodeExecutionEvent_InputValue `protobuf_oneof:"input_value"`
	// Types that are valid to be assigned to OutputResult:
	//	*NodeExecutionEvent_OutputUri
	//	*NodeExecutionEvent_Error
	//	*NodeExecutionEvent_OutputData
	OutputResult isNodeExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	// Additional metadata to do with this event's node target based
	// on the node type
	//
	// Types that are valid to be assigned to TargetMetadata:
	//	*NodeExecutionEvent_WorkflowNodeMetadata
	//	*NodeExecutionEvent_TaskNodeMetadata
	TargetMetadata isNodeExecutionEvent_TargetMetadata `protobuf_oneof:"target_metadata"`
	// [To be deprecated] Specifies which task (if any) launched this node.
	ParentTaskMetadata *ParentTaskExecutionMetadata `protobuf:"bytes,9,opt,name=parent_task_metadata,json=parentTaskMetadata,proto3" json:"parent_task_metadata,omitempty"`
	// Specifies the parent node of the current node execution. Node executions at level zero will not have a parent node.
	ParentNodeMetadata *ParentNodeExecutionMetadata `protobuf:"bytes,10,opt,name=parent_node_metadata,json=parentNodeMetadata,proto3" json:"parent_node_metadata,omitempty"`
	// Retry group to indicate grouping of nodes by retries
	RetryGroup string `protobuf:"bytes,11,opt,name=retry_group,json=retryGroup,proto3" json:"retry_group,omitempty"`
	// Identifier of the node in the original workflow/graph
	// This maps to value of WorkflowTemplate.nodes[X].id
	SpecNodeId string `protobuf:"bytes,12,opt,name=spec_node_id,json=specNodeId,proto3" json:"spec_node_id,omitempty"`
	// Friendly readable name for the node
	NodeName     string `protobuf:"bytes,13,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	EventVersion int32  `protobuf:"varint,16,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
	// Whether this node launched a subworkflow.
	IsParent bool `protobuf:"varint,17,opt,name=is_parent,json=isParent,proto3" json:"is_parent,omitempty"`
	// Whether this node yielded a dynamic workflow.
	IsDynamic bool `protobuf:"varint,18,opt,name=is_dynamic,json=isDynamic,proto3" json:"is_dynamic,omitempty"`
	// String location uniquely identifying where the deck HTML file is
	// NativeUrl specifies the url in the format of the configured storage provider (e.g. s3://my-bucket/randomstring/suffix.tar)
	DeckUri string `protobuf:"bytes,19,opt,name=deck_uri,json=deckUri,proto3" json:"deck_uri,omitempty"`
	// This timestamp represents the instant when the event was reported by the executing framework. For example,
	// when first processing a node the `occurred_at` timestamp should be the instant propeller makes progress, so when
	// literal inputs are initially copied. The event however will not be sent until after the copy completes.
	// Extracting both of these timestamps facilitates a more accurate portrayal of the evaluation time-series.
	ReportedAt           *timestamp.Timestamp `protobuf:"bytes,21,opt,name=reported_at,json=reportedAt,proto3" json:"reported_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*NodeExecutionEvent) Descriptor 

func (*NodeExecutionEvent) Descriptor() ([]byte, []int)

func (*NodeExecutionEvent) GetDeckUri added in v1.1.3 

func (m *NodeExecutionEvent) GetDeckUri() string

func (*NodeExecutionEvent) GetError 

func (m *NodeExecutionEvent) GetError() *core.ExecutionError

func (*NodeExecutionEvent) GetEventVersion added in v0.24.9 

func (m *NodeExecutionEvent) GetEventVersion() int32

func (*NodeExecutionEvent) GetId 

func (m *NodeExecutionEvent) GetId() *core.NodeExecutionIdentifier

func (*NodeExecutionEvent) GetInputData added in v1.2.9 

func (m *NodeExecutionEvent) GetInputData() *core.LiteralMap

func (*NodeExecutionEvent) GetInputUri 

func (m *NodeExecutionEvent) GetInputUri() string

func (*NodeExecutionEvent) GetInputValue added in v1.2.9 

func (m *NodeExecutionEvent) GetInputValue() isNodeExecutionEvent_InputValue

func (*NodeExecutionEvent) GetIsDynamic added in v0.24.9 

func (m *NodeExecutionEvent) GetIsDynamic() bool

func (*NodeExecutionEvent) GetIsParent added in v0.24.9 

func (m *NodeExecutionEvent) GetIsParent() bool

func (*NodeExecutionEvent) GetNodeName added in v0.18.15 

func (m *NodeExecutionEvent) GetNodeName() string

func (*NodeExecutionEvent) GetOccurredAt 

func (m *NodeExecutionEvent) GetOccurredAt() *timestamp.Timestamp

func (*NodeExecutionEvent) GetOutputData added in v0.19.20 

func (m *NodeExecutionEvent) GetOutputData() *core.LiteralMap

func (*NodeExecutionEvent) GetOutputResult 

func (m *NodeExecutionEvent) GetOutputResult() isNodeExecutionEvent_OutputResult

func (*NodeExecutionEvent) GetOutputUri 

func (m *NodeExecutionEvent) GetOutputUri() string

func (*NodeExecutionEvent) GetParentNodeMetadata added in v0.18.15 

func (m *NodeExecutionEvent) GetParentNodeMetadata() *ParentNodeExecutionMetadata

func (*NodeExecutionEvent) GetParentTaskMetadata 

func (m *NodeExecutionEvent) GetParentTaskMetadata() *ParentTaskExecutionMetadata

func (*NodeExecutionEvent) GetPhase 

func (m *NodeExecutionEvent) GetPhase() core.NodeExecution_Phase

func (*NodeExecutionEvent) GetProducerId 

func (m *NodeExecutionEvent) GetProducerId() string

func (*NodeExecutionEvent) GetReportedAt added in v1.2.10 

func (m *NodeExecutionEvent) GetReportedAt() *timestamp.Timestamp

func (*NodeExecutionEvent) GetRetryGroup added in v0.18.15 

func (m *NodeExecutionEvent) GetRetryGroup() string

func (*NodeExecutionEvent) GetSpecNodeId added in v0.18.15 

func (m *NodeExecutionEvent) GetSpecNodeId() string

func (*NodeExecutionEvent) GetTargetMetadata 

func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata

func (*NodeExecutionEvent) GetTaskNodeMetadata added in v0.18.15 

func (m *NodeExecutionEvent) GetTaskNodeMetadata() *TaskNodeMetadata

func (*NodeExecutionEvent) GetWorkflowNodeMetadata 

func (m *NodeExecutionEvent) GetWorkflowNodeMetadata() *WorkflowNodeMetadata

func (*NodeExecutionEvent) ProtoMessage 

func (*NodeExecutionEvent) ProtoMessage()

func (*NodeExecutionEvent) Reset 

func (m *NodeExecutionEvent) Reset()

func (*NodeExecutionEvent) String 

func (m *NodeExecutionEvent) String() string

func (*NodeExecutionEvent) Validate 

func (m *NodeExecutionEvent) Validate() error

Validate checks the field values on NodeExecutionEvent with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*NodeExecutionEvent) XXX_DiscardUnknown 

func (m *NodeExecutionEvent) XXX_DiscardUnknown()

func (*NodeExecutionEvent) XXX_Marshal 

func (m *NodeExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeExecutionEvent) XXX_Merge 

func (m *NodeExecutionEvent) XXX_Merge(src proto.Message)

func (*NodeExecutionEvent) XXX_OneofWrappers added in v0.16.1 

func (*NodeExecutionEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*NodeExecutionEvent) XXX_Size 

func (m *NodeExecutionEvent) XXX_Size() int

func (*NodeExecutionEvent) XXX_Unmarshal 

func (m *NodeExecutionEvent) XXX_Unmarshal(b []byte) error

type NodeExecutionEventValidationError 

type NodeExecutionEventValidationError struct {
	// contains filtered or unexported fields
}

NodeExecutionEventValidationError is the validation error returned by NodeExecutionEvent.Validate if the designated constraints aren't met.

func (NodeExecutionEventValidationError) Cause 

func (e NodeExecutionEventValidationError) Cause() error

Cause function returns cause value.

func (NodeExecutionEventValidationError) Error 

func (e NodeExecutionEventValidationError) Error() string

Error satisfies the builtin error interface

func (NodeExecutionEventValidationError) ErrorName 

func (e NodeExecutionEventValidationError) ErrorName() string

ErrorName returns error name.

func (NodeExecutionEventValidationError) Field 

func (e NodeExecutionEventValidationError) Field() string

Field function returns field value.

func (NodeExecutionEventValidationError) Key 

func (e NodeExecutionEventValidationError) Key() bool

Key function returns key value.

func (NodeExecutionEventValidationError) Reason 

func (e NodeExecutionEventValidationError) Reason() string

Reason function returns reason value.

type NodeExecutionEvent_Error 

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

type NodeExecutionEvent_InputData added in v1.2.9 

type NodeExecutionEvent_InputData struct {
	InputData *core.LiteralMap `protobuf:"bytes,20,opt,name=input_data,json=inputData,proto3,oneof"`
}

type NodeExecutionEvent_InputUri added in v1.2.9 

type NodeExecutionEvent_InputUri struct {
	InputUri string `protobuf:"bytes,5,opt,name=input_uri,json=inputUri,proto3,oneof"`
}

type NodeExecutionEvent_OutputData added in v0.19.20 

type NodeExecutionEvent_OutputData struct {
	OutputData *core.LiteralMap `protobuf:"bytes,15,opt,name=output_data,json=outputData,proto3,oneof"`
}

type NodeExecutionEvent_OutputUri 

type NodeExecutionEvent_OutputUri struct {
	OutputUri string `protobuf:"bytes,6,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type NodeExecutionEvent_TaskNodeMetadata added in v0.18.15 

type NodeExecutionEvent_TaskNodeMetadata struct {
	TaskNodeMetadata *TaskNodeMetadata `protobuf:"bytes,14,opt,name=task_node_metadata,json=taskNodeMetadata,proto3,oneof"`
}

type NodeExecutionEvent_WorkflowNodeMetadata 

type NodeExecutionEvent_WorkflowNodeMetadata struct {
	WorkflowNodeMetadata *WorkflowNodeMetadata `protobuf:"bytes,8,opt,name=workflow_node_metadata,json=workflowNodeMetadata,proto3,oneof"`
}

type ParentNodeExecutionMetadata added in v0.18.15 

type ParentNodeExecutionMetadata struct {
	// Unique identifier of the parent node id within the execution
	// This is value of core.NodeExecutionIdentifier.node_id of the parent node
	NodeId               string   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ParentNodeExecutionMetadata) Descriptor added in v0.18.15 

func (*ParentNodeExecutionMetadata) Descriptor() ([]byte, []int)

func (*ParentNodeExecutionMetadata) GetNodeId added in v0.18.15 

func (m *ParentNodeExecutionMetadata) GetNodeId() string

func (*ParentNodeExecutionMetadata) ProtoMessage added in v0.18.15 

func (*ParentNodeExecutionMetadata) ProtoMessage()

func (*ParentNodeExecutionMetadata) Reset added in v0.18.15 

func (m *ParentNodeExecutionMetadata) Reset()

func (*ParentNodeExecutionMetadata) String added in v0.18.15 

func (m *ParentNodeExecutionMetadata) String() string

func (*ParentNodeExecutionMetadata) Validate added in v0.18.15 

func (m *ParentNodeExecutionMetadata) Validate() error

Validate checks the field values on ParentNodeExecutionMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ParentNodeExecutionMetadata) XXX_DiscardUnknown added in v0.18.15 

func (m *ParentNodeExecutionMetadata) XXX_DiscardUnknown()

func (*ParentNodeExecutionMetadata) XXX_Marshal added in v0.18.15 

func (m *ParentNodeExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParentNodeExecutionMetadata) XXX_Merge added in v0.18.15 

func (m *ParentNodeExecutionMetadata) XXX_Merge(src proto.Message)

func (*ParentNodeExecutionMetadata) XXX_Size added in v0.18.15 

func (m *ParentNodeExecutionMetadata) XXX_Size() int

func (*ParentNodeExecutionMetadata) XXX_Unmarshal added in v0.18.15 

func (m *ParentNodeExecutionMetadata) XXX_Unmarshal(b []byte) error

type ParentNodeExecutionMetadataValidationError added in v0.18.15 

type ParentNodeExecutionMetadataValidationError struct {
	// contains filtered or unexported fields
}

ParentNodeExecutionMetadataValidationError is the validation error returned by ParentNodeExecutionMetadata.Validate if the designated constraints aren't met.

func (ParentNodeExecutionMetadataValidationError) Cause added in v0.18.15 

func (e ParentNodeExecutionMetadataValidationError) Cause() error

Cause function returns cause value.

func (ParentNodeExecutionMetadataValidationError) Error added in v0.18.15 

func (e ParentNodeExecutionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (ParentNodeExecutionMetadataValidationError) ErrorName added in v0.18.15 

func (e ParentNodeExecutionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (ParentNodeExecutionMetadataValidationError) Field added in v0.18.15 

func (e ParentNodeExecutionMetadataValidationError) Field() string

Field function returns field value.

func (ParentNodeExecutionMetadataValidationError) Key added in v0.18.15 

func (e ParentNodeExecutionMetadataValidationError) Key() bool

Key function returns key value.

func (ParentNodeExecutionMetadataValidationError) Reason added in v0.18.15 

func (e ParentNodeExecutionMetadataValidationError) Reason() string

Reason function returns reason value.

type ParentTaskExecutionMetadata 

type ParentTaskExecutionMetadata struct {
	Id                   *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*ParentTaskExecutionMetadata) Descriptor 

func (*ParentTaskExecutionMetadata) Descriptor() ([]byte, []int)

func (*ParentTaskExecutionMetadata) GetId 

func (m *ParentTaskExecutionMetadata) GetId() *core.TaskExecutionIdentifier

func (*ParentTaskExecutionMetadata) ProtoMessage 

func (*ParentTaskExecutionMetadata) ProtoMessage()

func (*ParentTaskExecutionMetadata) Reset 

func (m *ParentTaskExecutionMetadata) Reset()

func (*ParentTaskExecutionMetadata) String 

func (m *ParentTaskExecutionMetadata) String() string

func (*ParentTaskExecutionMetadata) Validate 

func (m *ParentTaskExecutionMetadata) Validate() error

Validate checks the field values on ParentTaskExecutionMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ParentTaskExecutionMetadata) XXX_DiscardUnknown 

func (m *ParentTaskExecutionMetadata) XXX_DiscardUnknown()

func (*ParentTaskExecutionMetadata) XXX_Marshal 

func (m *ParentTaskExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParentTaskExecutionMetadata) XXX_Merge 

func (m *ParentTaskExecutionMetadata) XXX_Merge(src proto.Message)

func (*ParentTaskExecutionMetadata) XXX_Size 

func (m *ParentTaskExecutionMetadata) XXX_Size() int

func (*ParentTaskExecutionMetadata) XXX_Unmarshal 

func (m *ParentTaskExecutionMetadata) XXX_Unmarshal(b []byte) error

type ParentTaskExecutionMetadataValidationError 

type ParentTaskExecutionMetadataValidationError struct {
	// contains filtered or unexported fields
}

ParentTaskExecutionMetadataValidationError is the validation error returned by ParentTaskExecutionMetadata.Validate if the designated constraints aren't met.

func (ParentTaskExecutionMetadataValidationError) Cause 

func (e ParentTaskExecutionMetadataValidationError) Cause() error

Cause function returns cause value.

func (ParentTaskExecutionMetadataValidationError) Error 

func (e ParentTaskExecutionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (ParentTaskExecutionMetadataValidationError) ErrorName 

func (e ParentTaskExecutionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (ParentTaskExecutionMetadataValidationError) Field 

func (e ParentTaskExecutionMetadataValidationError) Field() string

Field function returns field value.

func (ParentTaskExecutionMetadataValidationError) Key 

func (e ParentTaskExecutionMetadataValidationError) Key() bool

Key function returns key value.

func (ParentTaskExecutionMetadataValidationError) Reason 

func (e ParentTaskExecutionMetadataValidationError) Reason() string

Reason function returns reason value.

type ResourcePoolInfo added in v0.18.23 

type ResourcePoolInfo struct {
	// Unique resource ID used to identify this execution when allocating a token.
	AllocationToken string `protobuf:"bytes,1,opt,name=allocation_token,json=allocationToken,proto3" json:"allocation_token,omitempty"`
	// Namespace under which this task execution requested an allocation token.
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This message holds task execution metadata specific to resource allocation used to manage concurrent executions for a project namespace.

func (*ResourcePoolInfo) Descriptor added in v0.18.23 

func (*ResourcePoolInfo) Descriptor() ([]byte, []int)

func (*ResourcePoolInfo) GetAllocationToken added in v0.18.23 

func (m *ResourcePoolInfo) GetAllocationToken() string

func (*ResourcePoolInfo) GetNamespace added in v0.18.23 

func (m *ResourcePoolInfo) GetNamespace() string

func (*ResourcePoolInfo) ProtoMessage added in v0.18.23 

func (*ResourcePoolInfo) ProtoMessage()

func (*ResourcePoolInfo) Reset added in v0.18.23 

func (m *ResourcePoolInfo) Reset()

func (*ResourcePoolInfo) String added in v0.18.23 

func (m *ResourcePoolInfo) String() string

func (*ResourcePoolInfo) Validate added in v0.18.23 

func (m *ResourcePoolInfo) Validate() error

Validate checks the field values on ResourcePoolInfo with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ResourcePoolInfo) XXX_DiscardUnknown added in v0.18.23 

func (m *ResourcePoolInfo) XXX_DiscardUnknown()

func (*ResourcePoolInfo) XXX_Marshal added in v0.18.23 

func (m *ResourcePoolInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResourcePoolInfo) XXX_Merge added in v0.18.23 

func (m *ResourcePoolInfo) XXX_Merge(src proto.Message)

func (*ResourcePoolInfo) XXX_Size added in v0.18.23 

func (m *ResourcePoolInfo) XXX_Size() int

func (*ResourcePoolInfo) XXX_Unmarshal added in v0.18.23 

func (m *ResourcePoolInfo) XXX_Unmarshal(b []byte) error

type ResourcePoolInfoValidationError added in v0.18.23 

type ResourcePoolInfoValidationError struct {
	// contains filtered or unexported fields
}

ResourcePoolInfoValidationError is the validation error returned by ResourcePoolInfo.Validate if the designated constraints aren't met.

func (ResourcePoolInfoValidationError) Cause added in v0.18.23 

func (e ResourcePoolInfoValidationError) Cause() error

Cause function returns cause value.

func (ResourcePoolInfoValidationError) Error added in v0.18.23 

func (e ResourcePoolInfoValidationError) Error() string

Error satisfies the builtin error interface

func (ResourcePoolInfoValidationError) ErrorName added in v0.18.23 

func (e ResourcePoolInfoValidationError) ErrorName() string

ErrorName returns error name.

func (ResourcePoolInfoValidationError) Field added in v0.18.23 

func (e ResourcePoolInfoValidationError) Field() string

Field function returns field value.

func (ResourcePoolInfoValidationError) Key added in v0.18.23 

func (e ResourcePoolInfoValidationError) Key() bool

Key function returns key value.

func (ResourcePoolInfoValidationError) Reason added in v0.18.23 

func (e ResourcePoolInfoValidationError) Reason() string

Reason function returns reason value.

type TaskExecutionEvent 

type TaskExecutionEvent struct {
	// ID of the task. In combination with the retryAttempt this will indicate
	// the task execution uniquely for a given parent node execution.
	TaskId *core.Identifier `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// A task execution is always kicked off by a node execution, the event consumer
	// will use the parent_id to relate the task to it's parent node execution
	ParentNodeExecutionId *core.NodeExecutionIdentifier `` /* 128-byte string literal not displayed */
	// retry attempt number for this task, ie., 2 for the second attempt
	RetryAttempt uint32 `protobuf:"varint,3,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	// Phase associated with the event
	Phase core.TaskExecution_Phase `protobuf:"varint,4,opt,name=phase,proto3,enum=flyteidl.core.TaskExecution_Phase" json:"phase,omitempty"`
	// id of the process that sent this event, mainly for trace debugging
	ProducerId string `protobuf:"bytes,5,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	// log information for the task execution
	Logs []*core.TaskLog `protobuf:"bytes,6,rep,name=logs,proto3" json:"logs,omitempty"`
	// This timestamp represents when the original event occurred, it is generated
	// by the executor of the task.
	OccurredAt *timestamp.Timestamp `protobuf:"bytes,7,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are valid to be assigned to InputValue:
	//	*TaskExecutionEvent_InputUri
	//	*TaskExecutionEvent_InputData
	InputValue isTaskExecutionEvent_InputValue `protobuf_oneof:"input_value"`
	// Types that are valid to be assigned to OutputResult:
	//	*TaskExecutionEvent_OutputUri
	//	*TaskExecutionEvent_Error
	//	*TaskExecutionEvent_OutputData
	OutputResult isTaskExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	// Custom data that the task plugin sends back. This is extensible to allow various plugins in the system.
	CustomInfo *_struct.Struct `protobuf:"bytes,11,opt,name=custom_info,json=customInfo,proto3" json:"custom_info,omitempty"`
	// Some phases, like RUNNING, can send multiple events with changed metadata (new logs, additional custom_info, etc)
	// that should be recorded regardless of the lack of phase change.
	// The version field should be incremented when metadata changes across the duration of an individual phase.
	PhaseVersion uint32 `protobuf:"varint,12,opt,name=phase_version,json=phaseVersion,proto3" json:"phase_version,omitempty"`
	// An optional explanation for the phase transition.
	Reason string `protobuf:"bytes,13,opt,name=reason,proto3" json:"reason,omitempty"`
	// A predefined yet extensible Task type identifier. If the task definition is already registered in flyte admin
	// this type will be identical, but not all task executions necessarily use pre-registered definitions and this
	// type is useful to render the task in the UI, filter task executions, etc.
	TaskType string `protobuf:"bytes,14,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
	// Metadata around how a task was executed.
	Metadata *TaskExecutionMetadata `protobuf:"bytes,16,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The event version is used to indicate versioned changes in how data is reported using this
	// proto message. For example, event_verison > 0 means that maps tasks report logs using the
	// TaskExecutionMetadata ExternalResourceInfo fields for each subtask rather than the TaskLog
	// in this message.
	EventVersion int32 `protobuf:"varint,18,opt,name=event_version,json=eventVersion,proto3" json:"event_version,omitempty"`
	// This timestamp represents the instant when the event was reported by the executing framework. For example, a k8s
	// pod task may be marked completed at (ie. `occurred_at`) the instant the container running user code completes,
	// but this event will not be reported until the pod is marked as completed. Extracting both of these timestamps
	// facilitates a more accurate portrayal of the evaluation time-series.
	ReportedAt           *timestamp.Timestamp `protobuf:"bytes,20,opt,name=reported_at,json=reportedAt,proto3" json:"reported_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Plugin specific execution event information. For tasks like Python, Hive, Spark, DynamicJob.

func (*TaskExecutionEvent) Descriptor 

func (*TaskExecutionEvent) Descriptor() ([]byte, []int)

func (*TaskExecutionEvent) GetCustomInfo 

func (m *TaskExecutionEvent) GetCustomInfo() *_struct.Struct

func (*TaskExecutionEvent) GetError 

func (m *TaskExecutionEvent) GetError() *core.ExecutionError

func (*TaskExecutionEvent) GetEventVersion added in v0.24.17 

func (m *TaskExecutionEvent) GetEventVersion() int32

func (*TaskExecutionEvent) GetInputData added in v1.2.9 

func (m *TaskExecutionEvent) GetInputData() *core.LiteralMap

func (*TaskExecutionEvent) GetInputUri 

func (m *TaskExecutionEvent) GetInputUri() string

func (*TaskExecutionEvent) GetInputValue added in v1.2.9 

func (m *TaskExecutionEvent) GetInputValue() isTaskExecutionEvent_InputValue

func (*TaskExecutionEvent) GetLogs 

func (m *TaskExecutionEvent) GetLogs() []*core.TaskLog

func (*TaskExecutionEvent) GetMetadata added in v0.18.15 

func (m *TaskExecutionEvent) GetMetadata() *TaskExecutionMetadata

func (*TaskExecutionEvent) GetOccurredAt 

func (m *TaskExecutionEvent) GetOccurredAt() *timestamp.Timestamp

func (*TaskExecutionEvent) GetOutputData added in v0.19.20 

func (m *TaskExecutionEvent) GetOutputData() *core.LiteralMap

func (*TaskExecutionEvent) GetOutputResult 

func (m *TaskExecutionEvent) GetOutputResult() isTaskExecutionEvent_OutputResult

func (*TaskExecutionEvent) GetOutputUri 

func (m *TaskExecutionEvent) GetOutputUri() string

func (*TaskExecutionEvent) GetParentNodeExecutionId 

func (m *TaskExecutionEvent) GetParentNodeExecutionId() *core.NodeExecutionIdentifier

func (*TaskExecutionEvent) GetPhase 

func (m *TaskExecutionEvent) GetPhase() core.TaskExecution_Phase

func (*TaskExecutionEvent) GetPhaseVersion 

func (m *TaskExecutionEvent) GetPhaseVersion() uint32

func (*TaskExecutionEvent) GetProducerId 

func (m *TaskExecutionEvent) GetProducerId() string

func (*TaskExecutionEvent) GetReason added in v0.18.23 

func (m *TaskExecutionEvent) GetReason() string

func (*TaskExecutionEvent) GetReportedAt added in v1.2.10 

func (m *TaskExecutionEvent) GetReportedAt() *timestamp.Timestamp

func (*TaskExecutionEvent) GetRetryAttempt 

func (m *TaskExecutionEvent) GetRetryAttempt() uint32

func (*TaskExecutionEvent) GetTaskId 

func (m *TaskExecutionEvent) GetTaskId() *core.Identifier

func (*TaskExecutionEvent) GetTaskType added in v0.18.23 

func (m *TaskExecutionEvent) GetTaskType() string

func (*TaskExecutionEvent) ProtoMessage 

func (*TaskExecutionEvent) ProtoMessage()

func (*TaskExecutionEvent) Reset 

func (m *TaskExecutionEvent) Reset()

func (*TaskExecutionEvent) String 

func (m *TaskExecutionEvent) String() string

func (*TaskExecutionEvent) Validate 

func (m *TaskExecutionEvent) Validate() error

Validate checks the field values on TaskExecutionEvent with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionEvent) XXX_DiscardUnknown 

func (m *TaskExecutionEvent) XXX_DiscardUnknown()

func (*TaskExecutionEvent) XXX_Marshal 

func (m *TaskExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskExecutionEvent) XXX_Merge 

func (m *TaskExecutionEvent) XXX_Merge(src proto.Message)

func (*TaskExecutionEvent) XXX_OneofWrappers added in v0.16.1 

func (*TaskExecutionEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TaskExecutionEvent) XXX_Size 

func (m *TaskExecutionEvent) XXX_Size() int

func (*TaskExecutionEvent) XXX_Unmarshal 

func (m *TaskExecutionEvent) XXX_Unmarshal(b []byte) error

type TaskExecutionEventValidationError 

type TaskExecutionEventValidationError struct {
	// contains filtered or unexported fields
}

TaskExecutionEventValidationError is the validation error returned by TaskExecutionEvent.Validate if the designated constraints aren't met.

func (TaskExecutionEventValidationError) Cause 

func (e TaskExecutionEventValidationError) Cause() error

Cause function returns cause value.

func (TaskExecutionEventValidationError) Error 

func (e TaskExecutionEventValidationError) Error() string

Error satisfies the builtin error interface

func (TaskExecutionEventValidationError) ErrorName 

func (e TaskExecutionEventValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionEventValidationError) Field 

func (e TaskExecutionEventValidationError) Field() string

Field function returns field value.

func (TaskExecutionEventValidationError) Key 

func (e TaskExecutionEventValidationError) Key() bool

Key function returns key value.

func (TaskExecutionEventValidationError) Reason 

func (e TaskExecutionEventValidationError) Reason() string

Reason function returns reason value.

type TaskExecutionEvent_Error 

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

type TaskExecutionEvent_InputData added in v1.2.9 

type TaskExecutionEvent_InputData struct {
	InputData *core.LiteralMap `protobuf:"bytes,19,opt,name=input_data,json=inputData,proto3,oneof"`
}

type TaskExecutionEvent_InputUri added in v1.2.9 

type TaskExecutionEvent_InputUri struct {
	InputUri string `protobuf:"bytes,8,opt,name=input_uri,json=inputUri,proto3,oneof"`
}

type TaskExecutionEvent_OutputData added in v0.19.20 

type TaskExecutionEvent_OutputData struct {
	OutputData *core.LiteralMap `protobuf:"bytes,17,opt,name=output_data,json=outputData,proto3,oneof"`
}

type TaskExecutionEvent_OutputUri 

type TaskExecutionEvent_OutputUri struct {
	OutputUri string `protobuf:"bytes,9,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type TaskExecutionMetadata added in v0.18.15 

type TaskExecutionMetadata struct {
	// Unique, generated name for this task execution used by the backend.
	GeneratedName string `protobuf:"bytes,1,opt,name=generated_name,json=generatedName,proto3" json:"generated_name,omitempty"`
	// Additional data on external resources on other back-ends or platforms (e.g. Hive, Qubole, etc) launched by this task execution.
	ExternalResources []*ExternalResourceInfo `protobuf:"bytes,2,rep,name=external_resources,json=externalResources,proto3" json:"external_resources,omitempty"`
	// Includes additional data on concurrent resource management used during execution..
	// This is a repeated field because a plugin can request multiple resource allocations during execution.
	ResourcePoolInfo []*ResourcePoolInfo `protobuf:"bytes,3,rep,name=resource_pool_info,json=resourcePoolInfo,proto3" json:"resource_pool_info,omitempty"`
	// The identifier of the plugin used to execute this task.
	PluginIdentifier     string                              `protobuf:"bytes,4,opt,name=plugin_identifier,json=pluginIdentifier,proto3" json:"plugin_identifier,omitempty"`
	InstanceClass        TaskExecutionMetadata_InstanceClass `` /* 158-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

Holds metadata around how a task was executed. As a task transitions across event phases during execution some attributes, such its generated name, generated external resources, and more may grow in size but not change necessarily based on the phase transition that sparked the event update. Metadata is a container for these attributes across the task execution lifecycle.

func (*TaskExecutionMetadata) Descriptor added in v0.18.15 

func (*TaskExecutionMetadata) Descriptor() ([]byte, []int)

func (*TaskExecutionMetadata) GetExternalResources added in v0.18.23 

func (m *TaskExecutionMetadata) GetExternalResources() []*ExternalResourceInfo

func (*TaskExecutionMetadata) GetGeneratedName added in v0.18.23 

func (m *TaskExecutionMetadata) GetGeneratedName() string

func (*TaskExecutionMetadata) GetInstanceClass added in v0.18.15 

func (m *TaskExecutionMetadata) GetInstanceClass() TaskExecutionMetadata_InstanceClass

func (*TaskExecutionMetadata) GetPluginIdentifier added in v0.18.23 

func (m *TaskExecutionMetadata) GetPluginIdentifier() string

func (*TaskExecutionMetadata) GetResourcePoolInfo added in v0.18.23 

func (m *TaskExecutionMetadata) GetResourcePoolInfo() []*ResourcePoolInfo

func (*TaskExecutionMetadata) ProtoMessage added in v0.18.15 

func (*TaskExecutionMetadata) ProtoMessage()

func (*TaskExecutionMetadata) Reset added in v0.18.15 

func (m *TaskExecutionMetadata) Reset()

func (*TaskExecutionMetadata) String added in v0.18.15 

func (m *TaskExecutionMetadata) String() string

func (*TaskExecutionMetadata) Validate added in v0.18.15 

func (m *TaskExecutionMetadata) Validate() error

Validate checks the field values on TaskExecutionMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskExecutionMetadata) XXX_DiscardUnknown added in v0.18.15 

func (m *TaskExecutionMetadata) XXX_DiscardUnknown()

func (*TaskExecutionMetadata) XXX_Marshal added in v0.18.15 

func (m *TaskExecutionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskExecutionMetadata) XXX_Merge added in v0.18.15 

func (m *TaskExecutionMetadata) XXX_Merge(src proto.Message)

func (*TaskExecutionMetadata) XXX_Size added in v0.18.15 

func (m *TaskExecutionMetadata) XXX_Size() int

func (*TaskExecutionMetadata) XXX_Unmarshal added in v0.18.15 

func (m *TaskExecutionMetadata) XXX_Unmarshal(b []byte) error

type TaskExecutionMetadataValidationError added in v0.18.15 

type TaskExecutionMetadataValidationError struct {
	// contains filtered or unexported fields
}

TaskExecutionMetadataValidationError is the validation error returned by TaskExecutionMetadata.Validate if the designated constraints aren't met.

func (TaskExecutionMetadataValidationError) Cause added in v0.18.15 

func (e TaskExecutionMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskExecutionMetadataValidationError) Error added in v0.18.15 

func (e TaskExecutionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskExecutionMetadataValidationError) ErrorName added in v0.18.15 

func (e TaskExecutionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionMetadataValidationError) Field added in v0.18.15 

func (e TaskExecutionMetadataValidationError) Field() string

Field function returns field value.

func (TaskExecutionMetadataValidationError) Key added in v0.18.15 

func (e TaskExecutionMetadataValidationError) Key() bool

Key function returns key value.

func (TaskExecutionMetadataValidationError) Reason added in v0.18.15 

func (e TaskExecutionMetadataValidationError) Reason() string

Reason function returns reason value.

type TaskExecutionMetadata_InstanceClass added in v0.18.15 

type TaskExecutionMetadata_InstanceClass int32

Includes the broad category of machine used for this specific task execution. 

const (
	// The default instance class configured for the flyte application platform.
	TaskExecutionMetadata_DEFAULT TaskExecutionMetadata_InstanceClass = 0
	// The instance class configured for interruptible tasks.
	TaskExecutionMetadata_INTERRUPTIBLE TaskExecutionMetadata_InstanceClass = 1
)

func (TaskExecutionMetadata_InstanceClass) EnumDescriptor added in v0.18.15 

func (TaskExecutionMetadata_InstanceClass) EnumDescriptor() ([]byte, []int)

func (TaskExecutionMetadata_InstanceClass) String added in v0.18.15 

func (x TaskExecutionMetadata_InstanceClass) String() string

type TaskNodeMetadata added in v0.18.15 

type TaskNodeMetadata struct {
	// Captures the status of caching for this execution.
	CacheStatus core.CatalogCacheStatus `` /* 133-byte string literal not displayed */
	// This structure carries the catalog artifact information
	CatalogKey *core.CatalogMetadata `protobuf:"bytes,2,opt,name=catalog_key,json=catalogKey,proto3" json:"catalog_key,omitempty"`
	// Captures the status of cache reservations for this execution.
	ReservationStatus core.CatalogReservation_Status `` /* 158-byte string literal not displayed */
	// The latest checkpoint location
	CheckpointUri string `protobuf:"bytes,4,opt,name=checkpoint_uri,json=checkpointUri,proto3" json:"checkpoint_uri,omitempty"`
	// In the case this task launched a dynamic workflow we capture its structure here.
	DynamicWorkflow      *DynamicWorkflowNodeMetadata `protobuf:"bytes,16,opt,name=dynamic_workflow,json=dynamicWorkflow,proto3" json:"dynamic_workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*TaskNodeMetadata) Descriptor added in v0.18.15 

func (*TaskNodeMetadata) Descriptor() ([]byte, []int)

func (*TaskNodeMetadata) GetCacheStatus added in v0.18.15 

func (m *TaskNodeMetadata) GetCacheStatus() core.CatalogCacheStatus

func (*TaskNodeMetadata) GetCatalogKey added in v0.18.15 

func (m *TaskNodeMetadata) GetCatalogKey() *core.CatalogMetadata

func (*TaskNodeMetadata) GetCheckpointUri added in v1.1.17 

func (m *TaskNodeMetadata) GetCheckpointUri() string

func (*TaskNodeMetadata) GetDynamicWorkflow added in v0.18.33 

func (m *TaskNodeMetadata) GetDynamicWorkflow() *DynamicWorkflowNodeMetadata

func (*TaskNodeMetadata) GetReservationStatus added in v0.21.11 

func (m *TaskNodeMetadata) GetReservationStatus() core.CatalogReservation_Status

func (*TaskNodeMetadata) ProtoMessage added in v0.18.15 

func (*TaskNodeMetadata) ProtoMessage()

func (*TaskNodeMetadata) Reset added in v0.18.15 

func (m *TaskNodeMetadata) Reset()

func (*TaskNodeMetadata) String added in v0.18.15 

func (m *TaskNodeMetadata) String() string

func (*TaskNodeMetadata) Validate added in v0.18.15 

func (m *TaskNodeMetadata) Validate() error

Validate checks the field values on TaskNodeMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*TaskNodeMetadata) XXX_DiscardUnknown added in v0.18.15 

func (m *TaskNodeMetadata) XXX_DiscardUnknown()

func (*TaskNodeMetadata) XXX_Marshal added in v0.18.15 

func (m *TaskNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskNodeMetadata) XXX_Merge added in v0.18.15 

func (m *TaskNodeMetadata) XXX_Merge(src proto.Message)

func (*TaskNodeMetadata) XXX_Size added in v0.18.15 

func (m *TaskNodeMetadata) XXX_Size() int

func (*TaskNodeMetadata) XXX_Unmarshal added in v0.18.15 

func (m *TaskNodeMetadata) XXX_Unmarshal(b []byte) error

type TaskNodeMetadataValidationError added in v0.18.15 

type TaskNodeMetadataValidationError struct {
	// contains filtered or unexported fields
}

TaskNodeMetadataValidationError is the validation error returned by TaskNodeMetadata.Validate if the designated constraints aren't met.

func (TaskNodeMetadataValidationError) Cause added in v0.18.15 

func (e TaskNodeMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskNodeMetadataValidationError) Error added in v0.18.15 

func (e TaskNodeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskNodeMetadataValidationError) ErrorName added in v0.18.15 

func (e TaskNodeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskNodeMetadataValidationError) Field added in v0.18.15 

func (e TaskNodeMetadataValidationError) Field() string

Field function returns field value.

func (TaskNodeMetadataValidationError) Key added in v0.18.15 

func (e TaskNodeMetadataValidationError) Key() bool

Key function returns key value.

func (TaskNodeMetadataValidationError) Reason added in v0.18.15 

func (e TaskNodeMetadataValidationError) Reason() string

Reason function returns reason value.

type WorkflowExecutionEvent 

type WorkflowExecutionEvent struct {
	// Workflow execution id
	ExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// the id of the originator (Propeller) of the event
	ProducerId string                       `protobuf:"bytes,2,opt,name=producer_id,json=producerId,proto3" json:"producer_id,omitempty"`
	Phase      core.WorkflowExecution_Phase `protobuf:"varint,3,opt,name=phase,proto3,enum=flyteidl.core.WorkflowExecution_Phase" json:"phase,omitempty"`
	// This timestamp represents when the original event occurred, it is generated
	// by the executor of the workflow.
	OccurredAt *timestamp.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are valid to be assigned to OutputResult:
	//	*WorkflowExecutionEvent_OutputUri
	//	*WorkflowExecutionEvent_Error
	//	*WorkflowExecutionEvent_OutputData
	OutputResult         isWorkflowExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*WorkflowExecutionEvent) Descriptor 

func (*WorkflowExecutionEvent) Descriptor() ([]byte, []int)

func (*WorkflowExecutionEvent) GetError 

func (m *WorkflowExecutionEvent) GetError() *core.ExecutionError

func (*WorkflowExecutionEvent) GetExecutionId 

func (m *WorkflowExecutionEvent) GetExecutionId() *core.WorkflowExecutionIdentifier

func (*WorkflowExecutionEvent) GetOccurredAt 

func (m *WorkflowExecutionEvent) GetOccurredAt() *timestamp.Timestamp

func (*WorkflowExecutionEvent) GetOutputData added in v0.19.20 

func (m *WorkflowExecutionEvent) GetOutputData() *core.LiteralMap

func (*WorkflowExecutionEvent) GetOutputResult 

func (m *WorkflowExecutionEvent) GetOutputResult() isWorkflowExecutionEvent_OutputResult

func (*WorkflowExecutionEvent) GetOutputUri 

func (m *WorkflowExecutionEvent) GetOutputUri() string

func (*WorkflowExecutionEvent) GetPhase 

func (m *WorkflowExecutionEvent) GetPhase() core.WorkflowExecution_Phase

func (*WorkflowExecutionEvent) GetProducerId 

func (m *WorkflowExecutionEvent) GetProducerId() string

func (*WorkflowExecutionEvent) ProtoMessage 

func (*WorkflowExecutionEvent) ProtoMessage()

func (*WorkflowExecutionEvent) Reset 

func (m *WorkflowExecutionEvent) Reset()

func (*WorkflowExecutionEvent) String 

func (m *WorkflowExecutionEvent) String() string

func (*WorkflowExecutionEvent) Validate 

func (m *WorkflowExecutionEvent) Validate() error

Validate checks the field values on WorkflowExecutionEvent with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowExecutionEvent) XXX_DiscardUnknown 

func (m *WorkflowExecutionEvent) XXX_DiscardUnknown()

func (*WorkflowExecutionEvent) XXX_Marshal 

func (m *WorkflowExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecutionEvent) XXX_Merge 

func (m *WorkflowExecutionEvent) XXX_Merge(src proto.Message)

func (*WorkflowExecutionEvent) XXX_OneofWrappers added in v0.16.1 

func (*WorkflowExecutionEvent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*WorkflowExecutionEvent) XXX_Size 

func (m *WorkflowExecutionEvent) XXX_Size() int

func (*WorkflowExecutionEvent) XXX_Unmarshal 

func (m *WorkflowExecutionEvent) XXX_Unmarshal(b []byte) error

type WorkflowExecutionEventValidationError 

type WorkflowExecutionEventValidationError struct {
	// contains filtered or unexported fields
}

WorkflowExecutionEventValidationError is the validation error returned by WorkflowExecutionEvent.Validate if the designated constraints aren't met.

func (WorkflowExecutionEventValidationError) Cause 

func (e WorkflowExecutionEventValidationError) Cause() error

Cause function returns cause value.

func (WorkflowExecutionEventValidationError) Error 

func (e WorkflowExecutionEventValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowExecutionEventValidationError) ErrorName 

func (e WorkflowExecutionEventValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowExecutionEventValidationError) Field 

func (e WorkflowExecutionEventValidationError) Field() string

Field function returns field value.

func (WorkflowExecutionEventValidationError) Key 

func (e WorkflowExecutionEventValidationError) Key() bool

Key function returns key value.

func (WorkflowExecutionEventValidationError) Reason 

func (e WorkflowExecutionEventValidationError) Reason() string

Reason function returns reason value.

type WorkflowExecutionEvent_Error 

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

type WorkflowExecutionEvent_OutputData added in v0.19.20 

type WorkflowExecutionEvent_OutputData struct {
	OutputData *core.LiteralMap `protobuf:"bytes,7,opt,name=output_data,json=outputData,proto3,oneof"`
}

type WorkflowExecutionEvent_OutputUri 

type WorkflowExecutionEvent_OutputUri struct {
	OutputUri string `protobuf:"bytes,5,opt,name=output_uri,json=outputUri,proto3,oneof"`
}

type WorkflowNodeMetadata 

type WorkflowNodeMetadata struct {
	ExecutionId          *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

For Workflow Nodes we need to send information about the workflow that's launched

func (*WorkflowNodeMetadata) Descriptor 

func (*WorkflowNodeMetadata) Descriptor() ([]byte, []int)

func (*WorkflowNodeMetadata) GetExecutionId 

func (m *WorkflowNodeMetadata) GetExecutionId() *core.WorkflowExecutionIdentifier

func (*WorkflowNodeMetadata) ProtoMessage 

func (*WorkflowNodeMetadata) ProtoMessage()

func (*WorkflowNodeMetadata) Reset 

func (m *WorkflowNodeMetadata) Reset()

func (*WorkflowNodeMetadata) String 

func (m *WorkflowNodeMetadata) String() string

func (*WorkflowNodeMetadata) Validate 

func (m *WorkflowNodeMetadata) Validate() error

Validate checks the field values on WorkflowNodeMetadata with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*WorkflowNodeMetadata) XXX_DiscardUnknown 

func (m *WorkflowNodeMetadata) XXX_DiscardUnknown()

func (*WorkflowNodeMetadata) XXX_Marshal 

func (m *WorkflowNodeMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowNodeMetadata) XXX_Merge 

func (m *WorkflowNodeMetadata) XXX_Merge(src proto.Message)

func (*WorkflowNodeMetadata) XXX_Size 

func (m *WorkflowNodeMetadata) XXX_Size() int

func (*WorkflowNodeMetadata) XXX_Unmarshal 

func (m *WorkflowNodeMetadata) XXX_Unmarshal(b []byte) error

type WorkflowNodeMetadataValidationError 

type WorkflowNodeMetadataValidationError struct {
	// contains filtered or unexported fields
}

WorkflowNodeMetadataValidationError is the validation error returned by WorkflowNodeMetadata.Validate if the designated constraints aren't met.

func (WorkflowNodeMetadataValidationError) Cause 

func (e WorkflowNodeMetadataValidationError) Cause() error

Cause function returns cause value.

func (WorkflowNodeMetadataValidationError) Error 

func (e WorkflowNodeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (WorkflowNodeMetadataValidationError) ErrorName 

func (e WorkflowNodeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (WorkflowNodeMetadataValidationError) Field 

func (e WorkflowNodeMetadataValidationError) Field() string

Field function returns field value.

func (WorkflowNodeMetadataValidationError) Key 

func (e WorkflowNodeMetadataValidationError) Key() bool

Key function returns key value.

func (WorkflowNodeMetadataValidationError) Reason 

func (e WorkflowNodeMetadataValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.