event

package
v1.10.7-b1 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2024 License: Apache-2.0 Imports: 6 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 CloudEventExecutionStart added in v1.10.7 

type CloudEventExecutionStart struct {
	// The execution created.
	ExecutionId *core.WorkflowExecutionIdentifier `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// The launch plan used.
	LaunchPlanId *core.Identifier `protobuf:"bytes,2,opt,name=launch_plan_id,json=launchPlanId,proto3" json:"launch_plan_id,omitempty"`
	WorkflowId   *core.Identifier `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Artifact inputs to the workflow execution for which we have the full Artifact ID. These are likely the result of artifact queries that are run.
	ArtifactIds []*core.ArtifactID `protobuf:"bytes,4,rep,name=artifact_ids,json=artifactIds,proto3" json:"artifact_ids,omitempty"`
	// Artifact inputs to the workflow execution for which we only have the tracking bit that's installed into the Literal's metadata by the Artifact service.
	ArtifactTrackers     []string `protobuf:"bytes,5,rep,name=artifact_trackers,json=artifactTrackers,proto3" json:"artifact_trackers,omitempty"`
	Principal            string   `protobuf:"bytes,6,opt,name=principal,proto3" json:"principal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This event is to be sent by Admin after it creates an execution.

func (*CloudEventExecutionStart) Descriptor added in v1.10.7 

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

func (*CloudEventExecutionStart) GetArtifactIds added in v1.10.7 

func (m *CloudEventExecutionStart) GetArtifactIds() []*core.ArtifactID

func (*CloudEventExecutionStart) GetArtifactTrackers added in v1.10.7 

func (m *CloudEventExecutionStart) GetArtifactTrackers() []string

func (*CloudEventExecutionStart) GetExecutionId added in v1.10.7 

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

func (*CloudEventExecutionStart) GetLaunchPlanId added in v1.10.7 

func (m *CloudEventExecutionStart) GetLaunchPlanId() *core.Identifier

func (*CloudEventExecutionStart) GetPrincipal added in v1.10.7 

func (m *CloudEventExecutionStart) GetPrincipal() string

func (*CloudEventExecutionStart) GetWorkflowId added in v1.10.7 

func (m *CloudEventExecutionStart) GetWorkflowId() *core.Identifier

func (*CloudEventExecutionStart) ProtoMessage added in v1.10.7 

func (*CloudEventExecutionStart) ProtoMessage()

func (*CloudEventExecutionStart) Reset added in v1.10.7 

func (m *CloudEventExecutionStart) Reset()

func (*CloudEventExecutionStart) String added in v1.10.7 

func (m *CloudEventExecutionStart) String() string

func (*CloudEventExecutionStart) XXX_DiscardUnknown 

func (m *CloudEventExecutionStart) XXX_DiscardUnknown()

func (*CloudEventExecutionStart) XXX_Marshal 

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

func (*CloudEventExecutionStart) XXX_Merge 

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

func (*CloudEventExecutionStart) XXX_Size 

func (m *CloudEventExecutionStart) XXX_Size() int

func (*CloudEventExecutionStart) XXX_Unmarshal 

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

type CloudEventNodeExecution added in v1.10.7 

type CloudEventNodeExecution struct {
	RawEvent *NodeExecutionEvent `protobuf:"bytes,1,opt,name=raw_event,json=rawEvent,proto3" json:"raw_event,omitempty"`
	// The relevant task execution if applicable
	TaskExecId *core.TaskExecutionIdentifier `protobuf:"bytes,2,opt,name=task_exec_id,json=taskExecId,proto3" json:"task_exec_id,omitempty"`
	// The typed interface for the task that produced the event.
	OutputInterface *core.TypedInterface `protobuf:"bytes,3,opt,name=output_interface,json=outputInterface,proto3" json:"output_interface,omitempty"`
	// The following are ExecutionMetadata fields
	// We can't have the ExecutionMetadata object directly because of import cycle
	ArtifactIds []*core.ArtifactID `protobuf:"bytes,4,rep,name=artifact_ids,json=artifactIds,proto3" json:"artifact_ids,omitempty"`
	Principal   string             `protobuf:"bytes,5,opt,name=principal,proto3" json:"principal,omitempty"`
	// The ID of the LP that generated the execution that generated the Artifact.
	// Here for provenance information.
	// Launch plan IDs are easier to get than workflow IDs so we'll use these for now.
	LaunchPlanId         *core.Identifier `protobuf:"bytes,6,opt,name=launch_plan_id,json=launchPlanId,proto3" json:"launch_plan_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CloudEventNodeExecution) Descriptor added in v1.10.7 

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

func (*CloudEventNodeExecution) GetArtifactIds added in v1.10.7 

func (m *CloudEventNodeExecution) GetArtifactIds() []*core.ArtifactID

func (*CloudEventNodeExecution) GetLaunchPlanId added in v1.10.7 

func (m *CloudEventNodeExecution) GetLaunchPlanId() *core.Identifier

func (*CloudEventNodeExecution) GetOutputInterface added in v1.10.7 

func (m *CloudEventNodeExecution) GetOutputInterface() *core.TypedInterface

func (*CloudEventNodeExecution) GetPrincipal added in v1.10.7 

func (m *CloudEventNodeExecution) GetPrincipal() string

func (*CloudEventNodeExecution) GetRawEvent added in v1.10.7 

func (m *CloudEventNodeExecution) GetRawEvent() *NodeExecutionEvent

func (*CloudEventNodeExecution) GetTaskExecId added in v1.10.7 

func (m *CloudEventNodeExecution) GetTaskExecId() *core.TaskExecutionIdentifier

func (*CloudEventNodeExecution) ProtoMessage added in v1.10.7 

func (*CloudEventNodeExecution) ProtoMessage()

func (*CloudEventNodeExecution) Reset added in v1.10.7 

func (m *CloudEventNodeExecution) Reset()

func (*CloudEventNodeExecution) String added in v1.10.7 

func (m *CloudEventNodeExecution) String() string

func (*CloudEventNodeExecution) XXX_DiscardUnknown 

func (m *CloudEventNodeExecution) XXX_DiscardUnknown()

func (*CloudEventNodeExecution) XXX_Marshal 

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

func (*CloudEventNodeExecution) XXX_Merge 

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

func (*CloudEventNodeExecution) XXX_Size 

func (m *CloudEventNodeExecution) XXX_Size() int

func (*CloudEventNodeExecution) XXX_Unmarshal 

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

type CloudEventTaskExecution added in v1.10.7 

type CloudEventTaskExecution struct {
	RawEvent             *TaskExecutionEvent `protobuf:"bytes,1,opt,name=raw_event,json=rawEvent,proto3" json:"raw_event,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CloudEventTaskExecution) Descriptor added in v1.10.7 

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

func (*CloudEventTaskExecution) GetRawEvent added in v1.10.7 

func (m *CloudEventTaskExecution) GetRawEvent() *TaskExecutionEvent

func (*CloudEventTaskExecution) ProtoMessage added in v1.10.7 

func (*CloudEventTaskExecution) ProtoMessage()

func (*CloudEventTaskExecution) Reset added in v1.10.7 

func (m *CloudEventTaskExecution) Reset()

func (*CloudEventTaskExecution) String added in v1.10.7 

func (m *CloudEventTaskExecution) String() string

func (*CloudEventTaskExecution) XXX_DiscardUnknown 

func (m *CloudEventTaskExecution) XXX_DiscardUnknown()

func (*CloudEventTaskExecution) XXX_Marshal 

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

func (*CloudEventTaskExecution) XXX_Merge 

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

func (*CloudEventTaskExecution) XXX_Size 

func (m *CloudEventTaskExecution) XXX_Size() int

func (*CloudEventTaskExecution) XXX_Unmarshal 

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

type CloudEventWorkflowExecution added in v1.10.7 

type CloudEventWorkflowExecution struct {
	RawEvent        *WorkflowExecutionEvent `protobuf:"bytes,1,opt,name=raw_event,json=rawEvent,proto3" json:"raw_event,omitempty"`
	OutputInterface *core.TypedInterface    `protobuf:"bytes,2,opt,name=output_interface,json=outputInterface,proto3" json:"output_interface,omitempty"`
	// The following are ExecutionMetadata fields
	// We can't have the ExecutionMetadata object directly because of import cycle
	ArtifactIds        []*core.ArtifactID                `protobuf:"bytes,3,rep,name=artifact_ids,json=artifactIds,proto3" json:"artifact_ids,omitempty"`
	ReferenceExecution *core.WorkflowExecutionIdentifier `protobuf:"bytes,4,opt,name=reference_execution,json=referenceExecution,proto3" json:"reference_execution,omitempty"`
	Principal          string                            `protobuf:"bytes,5,opt,name=principal,proto3" json:"principal,omitempty"`
	// The ID of the LP that generated the execution that generated the Artifact.
	// Here for provenance information.
	// Launch plan IDs are easier to get than workflow IDs so we'll use these for now.
	LaunchPlanId         *core.Identifier `protobuf:"bytes,6,opt,name=launch_plan_id,json=launchPlanId,proto3" json:"launch_plan_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

This is the cloud event parallel to the raw WorkflowExecutionEvent message. It's filled in with additional information that downstream consumers may find useful.

func (*CloudEventWorkflowExecution) Descriptor added in v1.10.7 

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

func (*CloudEventWorkflowExecution) GetArtifactIds added in v1.10.7 

func (m *CloudEventWorkflowExecution) GetArtifactIds() []*core.ArtifactID

func (*CloudEventWorkflowExecution) GetLaunchPlanId added in v1.10.7 

func (m *CloudEventWorkflowExecution) GetLaunchPlanId() *core.Identifier

func (*CloudEventWorkflowExecution) GetOutputInterface added in v1.10.7 

func (m *CloudEventWorkflowExecution) GetOutputInterface() *core.TypedInterface

func (*CloudEventWorkflowExecution) GetPrincipal added in v1.10.7 

func (m *CloudEventWorkflowExecution) GetPrincipal() string

func (*CloudEventWorkflowExecution) GetRawEvent added in v1.10.7 

func (m *CloudEventWorkflowExecution) GetRawEvent() *WorkflowExecutionEvent

func (*CloudEventWorkflowExecution) GetReferenceExecution added in v1.10.7 

func (m *CloudEventWorkflowExecution) GetReferenceExecution() *core.WorkflowExecutionIdentifier

func (*CloudEventWorkflowExecution) ProtoMessage added in v1.10.7 

func (*CloudEventWorkflowExecution) ProtoMessage()

func (*CloudEventWorkflowExecution) Reset added in v1.10.7 

func (m *CloudEventWorkflowExecution) Reset()

func (*CloudEventWorkflowExecution) String added in v1.10.7 

func (m *CloudEventWorkflowExecution) String() string

func (*CloudEventWorkflowExecution) XXX_DiscardUnknown 

func (m *CloudEventWorkflowExecution) XXX_DiscardUnknown()

func (*CloudEventWorkflowExecution) XXX_Marshal 

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

func (*CloudEventWorkflowExecution) XXX_Merge 

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

func (*CloudEventWorkflowExecution) XXX_Size 

func (m *CloudEventWorkflowExecution) XXX_Size() int

func (*CloudEventWorkflowExecution) XXX_Unmarshal 

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

type DynamicWorkflowNodeMetadata 

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 

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

func (*DynamicWorkflowNodeMetadata) GetCompiledWorkflow 

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

func (*DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri 

func (m *DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri() string

func (*DynamicWorkflowNodeMetadata) GetId 

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

func (*DynamicWorkflowNodeMetadata) ProtoMessage 

func (*DynamicWorkflowNodeMetadata) ProtoMessage()

func (*DynamicWorkflowNodeMetadata) Reset 

func (m *DynamicWorkflowNodeMetadata) Reset()

func (*DynamicWorkflowNodeMetadata) String 

func (m *DynamicWorkflowNodeMetadata) String() string

func (*DynamicWorkflowNodeMetadata) XXX_DiscardUnknown 

func (m *DynamicWorkflowNodeMetadata) XXX_DiscardUnknown()

func (*DynamicWorkflowNodeMetadata) XXX_Marshal 

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

func (*DynamicWorkflowNodeMetadata) XXX_Merge 

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

func (*DynamicWorkflowNodeMetadata) XXX_Size 

func (m *DynamicWorkflowNodeMetadata) XXX_Size() int

func (*DynamicWorkflowNodeMetadata) XXX_Unmarshal 

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

type EventReason 

type EventReason struct {
	// An explanation for this event
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// The time this reason occurred
	OccurredAt           *timestamp.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*EventReason) Descriptor 

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

func (*EventReason) GetOccurredAt 

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

func (*EventReason) GetReason 

func (m *EventReason) GetReason() string

func (*EventReason) ProtoMessage 

func (*EventReason) ProtoMessage()

func (*EventReason) Reset 

func (m *EventReason) Reset()

func (*EventReason) String 

func (m *EventReason) String() string

func (*EventReason) XXX_DiscardUnknown 

func (m *EventReason) XXX_DiscardUnknown()

func (*EventReason) XXX_Marshal 

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

func (*EventReason) XXX_Merge 

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

func (*EventReason) XXX_Size 

func (m *EventReason) XXX_Size() int

func (*EventReason) XXX_Unmarshal 

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

type ExternalResourceInfo 

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 

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

func (*ExternalResourceInfo) GetCacheStatus 

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

func (*ExternalResourceInfo) GetExternalId 

func (m *ExternalResourceInfo) GetExternalId() string

func (*ExternalResourceInfo) GetIndex 

func (m *ExternalResourceInfo) GetIndex() uint32

func (*ExternalResourceInfo) GetLogs 

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

func (*ExternalResourceInfo) GetPhase 

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

func (*ExternalResourceInfo) GetRetryAttempt 

func (m *ExternalResourceInfo) GetRetryAttempt() uint32

func (*ExternalResourceInfo) ProtoMessage 

func (*ExternalResourceInfo) ProtoMessage()

func (*ExternalResourceInfo) Reset 

func (m *ExternalResourceInfo) Reset()

func (*ExternalResourceInfo) String 

func (m *ExternalResourceInfo) String() string

func (*ExternalResourceInfo) XXX_DiscardUnknown 

func (m *ExternalResourceInfo) XXX_DiscardUnknown()

func (*ExternalResourceInfo) XXX_Marshal 

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

func (*ExternalResourceInfo) XXX_Merge 

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

func (*ExternalResourceInfo) XXX_Size 

func (m *ExternalResourceInfo) XXX_Size() int

func (*ExternalResourceInfo) XXX_Unmarshal 

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

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"`
	// Indicates if this node is an ArrayNode.
	IsArray              bool     `protobuf:"varint,22,opt,name=is_array,json=isArray,proto3" json:"is_array,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeExecutionEvent) Descriptor 

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

func (*NodeExecutionEvent) GetDeckUri 

func (m *NodeExecutionEvent) GetDeckUri() string

func (*NodeExecutionEvent) GetError 

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

func (*NodeExecutionEvent) GetEventVersion 

func (m *NodeExecutionEvent) GetEventVersion() int32

func (*NodeExecutionEvent) GetId 

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

func (*NodeExecutionEvent) GetInputData 

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

func (*NodeExecutionEvent) GetInputUri 

func (m *NodeExecutionEvent) GetInputUri() string

func (*NodeExecutionEvent) GetInputValue 

func (m *NodeExecutionEvent) GetInputValue() isNodeExecutionEvent_InputValue

func (*NodeExecutionEvent) GetIsArray added in v1.9.14 

func (m *NodeExecutionEvent) GetIsArray() bool

func (*NodeExecutionEvent) GetIsDynamic 

func (m *NodeExecutionEvent) GetIsDynamic() bool

func (*NodeExecutionEvent) GetIsParent 

func (m *NodeExecutionEvent) GetIsParent() bool

func (*NodeExecutionEvent) GetNodeName 

func (m *NodeExecutionEvent) GetNodeName() string

func (*NodeExecutionEvent) GetOccurredAt 

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

func (*NodeExecutionEvent) GetOutputData 

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 

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 

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

func (*NodeExecutionEvent) GetRetryGroup 

func (m *NodeExecutionEvent) GetRetryGroup() string

func (*NodeExecutionEvent) GetSpecNodeId 

func (m *NodeExecutionEvent) GetSpecNodeId() string

func (*NodeExecutionEvent) GetTargetMetadata 

func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata

func (*NodeExecutionEvent) GetTaskNodeMetadata 

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

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 NodeExecutionEvent_Error 

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

type NodeExecutionEvent_InputData 

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

type NodeExecutionEvent_InputUri 

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

type NodeExecutionEvent_OutputData 

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 

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 

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 

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

func (*ParentNodeExecutionMetadata) GetNodeId 

func (m *ParentNodeExecutionMetadata) GetNodeId() string

func (*ParentNodeExecutionMetadata) ProtoMessage 

func (*ParentNodeExecutionMetadata) ProtoMessage()

func (*ParentNodeExecutionMetadata) Reset 

func (m *ParentNodeExecutionMetadata) Reset()

func (*ParentNodeExecutionMetadata) String 

func (m *ParentNodeExecutionMetadata) String() string

func (*ParentNodeExecutionMetadata) XXX_DiscardUnknown 

func (m *ParentNodeExecutionMetadata) XXX_DiscardUnknown()

func (*ParentNodeExecutionMetadata) XXX_Marshal 

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

func (*ParentNodeExecutionMetadata) XXX_Merge 

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

func (*ParentNodeExecutionMetadata) XXX_Size 

func (m *ParentNodeExecutionMetadata) XXX_Size() int

func (*ParentNodeExecutionMetadata) XXX_Unmarshal 

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

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

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 

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

func (*ResourcePoolInfo) GetAllocationToken 

func (m *ResourcePoolInfo) GetAllocationToken() string

func (*ResourcePoolInfo) GetNamespace 

func (m *ResourcePoolInfo) GetNamespace() string

func (*ResourcePoolInfo) ProtoMessage 

func (*ResourcePoolInfo) ProtoMessage()

func (*ResourcePoolInfo) Reset 

func (m *ResourcePoolInfo) Reset()

func (*ResourcePoolInfo) String 

func (m *ResourcePoolInfo) String() string

func (*ResourcePoolInfo) XXX_DiscardUnknown 

func (m *ResourcePoolInfo) XXX_DiscardUnknown()

func (*ResourcePoolInfo) XXX_Marshal 

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

func (*ResourcePoolInfo) XXX_Merge 

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

func (*ResourcePoolInfo) XXX_Size 

func (m *ResourcePoolInfo) XXX_Size() int

func (*ResourcePoolInfo) XXX_Unmarshal 

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

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.
	// Deprecated: Use reasons instead.
	Reason string `protobuf:"bytes,13,opt,name=reason,proto3" json:"reason,omitempty"` // Deprecated: Do not use.
	// An optional list of explanations for the phase transition.
	Reasons []*EventReason `protobuf:"bytes,21,rep,name=reasons,proto3" json:"reasons,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 

func (m *TaskExecutionEvent) GetEventVersion() int32

func (*TaskExecutionEvent) GetInputData 

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

func (*TaskExecutionEvent) GetInputUri 

func (m *TaskExecutionEvent) GetInputUri() string

func (*TaskExecutionEvent) GetInputValue 

func (m *TaskExecutionEvent) GetInputValue() isTaskExecutionEvent_InputValue

func (*TaskExecutionEvent) GetLogs 

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

func (*TaskExecutionEvent) GetMetadata 

func (m *TaskExecutionEvent) GetMetadata() *TaskExecutionMetadata

func (*TaskExecutionEvent) GetOccurredAt 

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

func (*TaskExecutionEvent) GetOutputData 

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 deprecated 

func (m *TaskExecutionEvent) GetReason() string

Deprecated: Do not use.

func (*TaskExecutionEvent) GetReasons 

func (m *TaskExecutionEvent) GetReasons() []*EventReason

func (*TaskExecutionEvent) GetReportedAt 

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 

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

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 TaskExecutionEvent_Error 

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

type TaskExecutionEvent_InputData 

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

type TaskExecutionEvent_InputUri 

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

type TaskExecutionEvent_OutputData 

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 

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 

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

func (*TaskExecutionMetadata) GetExternalResources 

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

func (*TaskExecutionMetadata) GetGeneratedName 

func (m *TaskExecutionMetadata) GetGeneratedName() string

func (*TaskExecutionMetadata) GetInstanceClass 

func (m *TaskExecutionMetadata) GetInstanceClass() TaskExecutionMetadata_InstanceClass

func (*TaskExecutionMetadata) GetPluginIdentifier 

func (m *TaskExecutionMetadata) GetPluginIdentifier() string

func (*TaskExecutionMetadata) GetResourcePoolInfo 

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

func (*TaskExecutionMetadata) ProtoMessage 

func (*TaskExecutionMetadata) ProtoMessage()

func (*TaskExecutionMetadata) Reset 

func (m *TaskExecutionMetadata) Reset()

func (*TaskExecutionMetadata) String 

func (m *TaskExecutionMetadata) String() string

func (*TaskExecutionMetadata) XXX_DiscardUnknown 

func (m *TaskExecutionMetadata) XXX_DiscardUnknown()

func (*TaskExecutionMetadata) XXX_Marshal 

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

func (*TaskExecutionMetadata) XXX_Merge 

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

func (*TaskExecutionMetadata) XXX_Size 

func (m *TaskExecutionMetadata) XXX_Size() int

func (*TaskExecutionMetadata) XXX_Unmarshal 

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

type TaskExecutionMetadata_InstanceClass 

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 

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

func (TaskExecutionMetadata_InstanceClass) String 

func (x TaskExecutionMetadata_InstanceClass) String() string

type TaskNodeMetadata 

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 

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

func (*TaskNodeMetadata) GetCacheStatus 

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

func (*TaskNodeMetadata) GetCatalogKey 

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

func (*TaskNodeMetadata) GetCheckpointUri 

func (m *TaskNodeMetadata) GetCheckpointUri() string

func (*TaskNodeMetadata) GetDynamicWorkflow 

func (m *TaskNodeMetadata) GetDynamicWorkflow() *DynamicWorkflowNodeMetadata

func (*TaskNodeMetadata) GetReservationStatus 

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

func (*TaskNodeMetadata) ProtoMessage 

func (*TaskNodeMetadata) ProtoMessage()

func (*TaskNodeMetadata) Reset 

func (m *TaskNodeMetadata) Reset()

func (*TaskNodeMetadata) String 

func (m *TaskNodeMetadata) String() string

func (*TaskNodeMetadata) XXX_DiscardUnknown 

func (m *TaskNodeMetadata) XXX_DiscardUnknown()

func (*TaskNodeMetadata) XXX_Marshal 

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

func (*TaskNodeMetadata) XXX_Merge 

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

func (*TaskNodeMetadata) XXX_Size 

func (m *TaskNodeMetadata) XXX_Size() int

func (*TaskNodeMetadata) XXX_Unmarshal 

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

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 

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

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 WorkflowExecutionEvent_Error 

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

type WorkflowExecutionEvent_OutputData 

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

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.