event

package
v0.18.14 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2021 License: Apache-2.0 Imports: 16 Imported by: 0

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 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"`
	InputUri   string               `protobuf:"bytes,5,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Types that are valid to be assigned to OutputResult:
	//	*NodeExecutionEvent_OutputUri
	//	*NodeExecutionEvent_Error
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeExecutionEvent) Descriptor 

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

func (*NodeExecutionEvent) GetError 

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

func (*NodeExecutionEvent) GetId 

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

func (*NodeExecutionEvent) GetInputUri 

func (m *NodeExecutionEvent) GetInputUri() string

func (*NodeExecutionEvent) GetNodeName added in v0.17.37 

func (m *NodeExecutionEvent) GetNodeName() string

func (*NodeExecutionEvent) GetOccurredAt 

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

func (*NodeExecutionEvent) GetOutputResult 

func (m *NodeExecutionEvent) GetOutputResult() isNodeExecutionEvent_OutputResult

func (*NodeExecutionEvent) GetOutputUri 

func (m *NodeExecutionEvent) GetOutputUri() string

func (*NodeExecutionEvent) GetParentNodeMetadata added in v0.17.37 

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) GetRetryGroup added in v0.17.37 

func (m *NodeExecutionEvent) GetRetryGroup() string

func (*NodeExecutionEvent) GetSpecNodeId added in v0.17.37 

func (m *NodeExecutionEvent) GetSpecNodeId() string

func (*NodeExecutionEvent) GetTargetMetadata 

func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata

func (*NodeExecutionEvent) GetTaskNodeMetadata added in v0.17.38 

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.4.20 

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_OutputUri 

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

type NodeExecutionEvent_TaskNodeMetadata added in v0.17.38 

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.17.37 

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.17.37 

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

func (*ParentNodeExecutionMetadata) GetNodeId added in v0.17.37 

func (m *ParentNodeExecutionMetadata) GetNodeId() string

func (*ParentNodeExecutionMetadata) ProtoMessage added in v0.17.37 

func (*ParentNodeExecutionMetadata) ProtoMessage()

func (*ParentNodeExecutionMetadata) Reset added in v0.17.37 

func (m *ParentNodeExecutionMetadata) Reset()

func (*ParentNodeExecutionMetadata) String added in v0.17.37 

func (m *ParentNodeExecutionMetadata) String() string

func (*ParentNodeExecutionMetadata) Validate added in v0.17.37 

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.17.37 

func (m *ParentNodeExecutionMetadata) XXX_DiscardUnknown()

func (*ParentNodeExecutionMetadata) XXX_Marshal added in v0.17.37 

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

func (*ParentNodeExecutionMetadata) XXX_Merge added in v0.17.37 

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

func (*ParentNodeExecutionMetadata) XXX_Size added in v0.17.37 

func (m *ParentNodeExecutionMetadata) XXX_Size() int

func (*ParentNodeExecutionMetadata) XXX_Unmarshal added in v0.17.37 

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

type ParentNodeExecutionMetadataValidationError added in v0.17.37 

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.17.37 

func (e ParentNodeExecutionMetadataValidationError) Cause() error

Cause function returns cause value.

func (ParentNodeExecutionMetadataValidationError) Error added in v0.17.37 

func (e ParentNodeExecutionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (ParentNodeExecutionMetadataValidationError) ErrorName added in v0.17.37 

func (e ParentNodeExecutionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (ParentNodeExecutionMetadataValidationError) Field added in v0.17.37 

func (e ParentNodeExecutionMetadataValidationError) Field() string

Field function returns field value.

func (ParentNodeExecutionMetadataValidationError) Key added in v0.17.37 

func (e ParentNodeExecutionMetadataValidationError) Key() bool

Key function returns key value.

func (ParentNodeExecutionMetadataValidationError) Reason added in v0.17.37 

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 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"`
	// URI of the input file, it encodes all the information
	// including Cloud source provider. ie., s3://...
	InputUri string `protobuf:"bytes,8,opt,name=input_uri,json=inputUri,proto3" json:"input_uri,omitempty"`
	// Types that are valid to be assigned to OutputResult:
	//	*TaskExecutionEvent_OutputUri
	//	*TaskExecutionEvent_Error
	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"`
	// Metadata around how a task was executed.
	Metadata             *TaskExecutionMetadata `protobuf:"bytes,16,opt,name=metadata,proto3" json:"metadata,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) GetInputUri 

func (m *TaskExecutionEvent) GetInputUri() string

func (*TaskExecutionEvent) GetLogs 

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

func (*TaskExecutionEvent) GetMetadata added in v0.18.7 

func (m *TaskExecutionEvent) GetMetadata() *TaskExecutionMetadata

func (*TaskExecutionEvent) GetOccurredAt 

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

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) GetRetryAttempt 

func (m *TaskExecutionEvent) GetRetryAttempt() uint32

func (*TaskExecutionEvent) GetTaskId 

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

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.4.20 

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_OutputUri 

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

type TaskExecutionMetadata added in v0.18.7 

type TaskExecutionMetadata struct {
	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. TODO(katrogan): Extend to include freeform fields (https://github.com/lyft/flyte/issues/325).

func (*TaskExecutionMetadata) Descriptor added in v0.18.7 

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

func (*TaskExecutionMetadata) GetInstanceClass added in v0.18.7 

func (m *TaskExecutionMetadata) GetInstanceClass() TaskExecutionMetadata_InstanceClass

func (*TaskExecutionMetadata) ProtoMessage added in v0.18.7 

func (*TaskExecutionMetadata) ProtoMessage()

func (*TaskExecutionMetadata) Reset added in v0.18.7 

func (m *TaskExecutionMetadata) Reset()

func (*TaskExecutionMetadata) String added in v0.18.7 

func (m *TaskExecutionMetadata) String() string

func (*TaskExecutionMetadata) Validate added in v0.18.7 

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.7 

func (m *TaskExecutionMetadata) XXX_DiscardUnknown()

func (*TaskExecutionMetadata) XXX_Marshal added in v0.18.7 

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

func (*TaskExecutionMetadata) XXX_Merge added in v0.18.7 

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

func (*TaskExecutionMetadata) XXX_Size added in v0.18.7 

func (m *TaskExecutionMetadata) XXX_Size() int

func (*TaskExecutionMetadata) XXX_Unmarshal added in v0.18.7 

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

type TaskExecutionMetadataValidationError added in v0.18.7 

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.7 

func (e TaskExecutionMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskExecutionMetadataValidationError) Error added in v0.18.7 

func (e TaskExecutionMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskExecutionMetadataValidationError) ErrorName added in v0.18.7 

func (e TaskExecutionMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskExecutionMetadataValidationError) Field added in v0.18.7 

func (e TaskExecutionMetadataValidationError) Field() string

Field function returns field value.

func (TaskExecutionMetadataValidationError) Key added in v0.18.7 

func (e TaskExecutionMetadataValidationError) Key() bool

Key function returns key value.

func (TaskExecutionMetadataValidationError) Reason added in v0.18.7 

func (e TaskExecutionMetadataValidationError) Reason() string

Reason function returns reason value.

type TaskExecutionMetadata_InstanceClass added in v0.18.7 

type TaskExecutionMetadata_InstanceClass int32

Includes the broad cateogry 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.7 

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

func (TaskExecutionMetadata_InstanceClass) String added in v0.18.7 

func (x TaskExecutionMetadata_InstanceClass) String() string

type TaskNodeMetadata added in v0.17.38 

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"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*TaskNodeMetadata) Descriptor added in v0.17.38 

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

func (*TaskNodeMetadata) GetCacheStatus added in v0.17.38 

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

func (*TaskNodeMetadata) GetCatalogKey added in v0.17.38 

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

func (*TaskNodeMetadata) ProtoMessage added in v0.17.38 

func (*TaskNodeMetadata) ProtoMessage()

func (*TaskNodeMetadata) Reset added in v0.17.38 

func (m *TaskNodeMetadata) Reset()

func (*TaskNodeMetadata) String added in v0.17.38 

func (m *TaskNodeMetadata) String() string

func (*TaskNodeMetadata) Validate added in v0.17.38 

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.17.38 

func (m *TaskNodeMetadata) XXX_DiscardUnknown()

func (*TaskNodeMetadata) XXX_Marshal added in v0.17.38 

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

func (*TaskNodeMetadata) XXX_Merge added in v0.17.38 

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

func (*TaskNodeMetadata) XXX_Size added in v0.17.38 

func (m *TaskNodeMetadata) XXX_Size() int

func (*TaskNodeMetadata) XXX_Unmarshal added in v0.17.38 

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

type TaskNodeMetadataValidationError added in v0.17.38 

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.17.38 

func (e TaskNodeMetadataValidationError) Cause() error

Cause function returns cause value.

func (TaskNodeMetadataValidationError) Error added in v0.17.38 

func (e TaskNodeMetadataValidationError) Error() string

Error satisfies the builtin error interface

func (TaskNodeMetadataValidationError) ErrorName added in v0.17.38 

func (e TaskNodeMetadataValidationError) ErrorName() string

ErrorName returns error name.

func (TaskNodeMetadataValidationError) Field added in v0.17.38 

func (e TaskNodeMetadataValidationError) Field() string

Field function returns field value.

func (TaskNodeMetadataValidationError) Key added in v0.17.38 

func (e TaskNodeMetadataValidationError) Key() bool

Key function returns key value.

func (TaskNodeMetadataValidationError) Reason added in v0.17.38 

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
	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) 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.4.20 

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_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.