event

package
v1.11.1-b0 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2024 License: Apache-2.0 Imports: 7 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for TaskExecutionMetadata_InstanceClass.

View Source 
var File_flyteidl_event_cloudevents_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_event_event_proto protoreflect.FileDescriptor

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"`
	// contains filtered or unexported fields
}

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

func (*CloudEventExecutionStart) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use CloudEventExecutionStart.ProtoReflect.Descriptor instead.

func (*CloudEventExecutionStart) GetArtifactIds added in v1.10.7 

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

func (*CloudEventExecutionStart) GetArtifactTrackers added in v1.10.7 

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

func (*CloudEventExecutionStart) GetExecutionId added in v1.10.7 

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

func (*CloudEventExecutionStart) GetLaunchPlanId added in v1.10.7 

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

func (*CloudEventExecutionStart) GetPrincipal added in v1.10.7 

func (x *CloudEventExecutionStart) GetPrincipal() string

func (*CloudEventExecutionStart) GetWorkflowId added in v1.10.7 

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

func (*CloudEventExecutionStart) ProtoMessage added in v1.10.7 

func (*CloudEventExecutionStart) ProtoMessage()

func (*CloudEventExecutionStart) ProtoReflect added in v1.10.7 

func (x *CloudEventExecutionStart) ProtoReflect() protoreflect.Message

func (*CloudEventExecutionStart) Reset added in v1.10.7 

func (x *CloudEventExecutionStart) Reset()

func (*CloudEventExecutionStart) String added in v1.10.7 

func (x *CloudEventExecutionStart) String() string

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"`
	// contains filtered or unexported fields
}

func (*CloudEventNodeExecution) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use CloudEventNodeExecution.ProtoReflect.Descriptor instead.

func (*CloudEventNodeExecution) GetArtifactIds added in v1.10.7 

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

func (*CloudEventNodeExecution) GetLaunchPlanId added in v1.10.7 

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

func (*CloudEventNodeExecution) GetOutputInterface added in v1.10.7 

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

func (*CloudEventNodeExecution) GetPrincipal added in v1.10.7 

func (x *CloudEventNodeExecution) GetPrincipal() string

func (*CloudEventNodeExecution) GetRawEvent added in v1.10.7 

func (x *CloudEventNodeExecution) GetRawEvent() *NodeExecutionEvent

func (*CloudEventNodeExecution) GetTaskExecId added in v1.10.7 

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

func (*CloudEventNodeExecution) ProtoMessage added in v1.10.7 

func (*CloudEventNodeExecution) ProtoMessage()

func (*CloudEventNodeExecution) ProtoReflect added in v1.10.7 

func (x *CloudEventNodeExecution) ProtoReflect() protoreflect.Message

func (*CloudEventNodeExecution) Reset added in v1.10.7 

func (x *CloudEventNodeExecution) Reset()

func (*CloudEventNodeExecution) String added in v1.10.7 

func (x *CloudEventNodeExecution) String() string

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"`
	// contains filtered or unexported fields
}

func (*CloudEventTaskExecution) Descriptor deprecated added in v1.10.7 

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

Deprecated: Use CloudEventTaskExecution.ProtoReflect.Descriptor instead.

func (*CloudEventTaskExecution) GetRawEvent added in v1.10.7 

func (x *CloudEventTaskExecution) GetRawEvent() *TaskExecutionEvent

func (*CloudEventTaskExecution) ProtoMessage added in v1.10.7 

func (*CloudEventTaskExecution) ProtoMessage()

func (*CloudEventTaskExecution) ProtoReflect added in v1.10.7 

func (x *CloudEventTaskExecution) ProtoReflect() protoreflect.Message

func (*CloudEventTaskExecution) Reset added in v1.10.7 

func (x *CloudEventTaskExecution) Reset()

func (*CloudEventTaskExecution) String added in v1.10.7 

func (x *CloudEventTaskExecution) String() string

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"`
	// contains filtered or unexported fields
}

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 deprecated added in v1.10.7 

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

Deprecated: Use CloudEventWorkflowExecution.ProtoReflect.Descriptor instead.

func (*CloudEventWorkflowExecution) GetArtifactIds added in v1.10.7 

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

func (*CloudEventWorkflowExecution) GetLaunchPlanId added in v1.10.7 

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

func (*CloudEventWorkflowExecution) GetOutputInterface added in v1.10.7 

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

func (*CloudEventWorkflowExecution) GetPrincipal added in v1.10.7 

func (x *CloudEventWorkflowExecution) GetPrincipal() string

func (*CloudEventWorkflowExecution) GetRawEvent added in v1.10.7 

func (x *CloudEventWorkflowExecution) GetRawEvent() *WorkflowExecutionEvent

func (*CloudEventWorkflowExecution) GetReferenceExecution added in v1.10.7 

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

func (*CloudEventWorkflowExecution) ProtoMessage added in v1.10.7 

func (*CloudEventWorkflowExecution) ProtoMessage()

func (*CloudEventWorkflowExecution) ProtoReflect added in v1.10.7 

func (x *CloudEventWorkflowExecution) ProtoReflect() protoreflect.Message

func (*CloudEventWorkflowExecution) Reset added in v1.10.7 

func (x *CloudEventWorkflowExecution) Reset()

func (*CloudEventWorkflowExecution) String added in v1.10.7 

func (x *CloudEventWorkflowExecution) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*DynamicWorkflowNodeMetadata) Descriptor deprecated 

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

Deprecated: Use DynamicWorkflowNodeMetadata.ProtoReflect.Descriptor instead.

func (*DynamicWorkflowNodeMetadata) GetCompiledWorkflow 

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

func (*DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri 

func (x *DynamicWorkflowNodeMetadata) GetDynamicJobSpecUri() string

func (*DynamicWorkflowNodeMetadata) GetId 

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

func (*DynamicWorkflowNodeMetadata) ProtoMessage 

func (*DynamicWorkflowNodeMetadata) ProtoMessage()

func (*DynamicWorkflowNodeMetadata) ProtoReflect added in v1.10.7 

func (x *DynamicWorkflowNodeMetadata) ProtoReflect() protoreflect.Message

func (*DynamicWorkflowNodeMetadata) Reset 

func (x *DynamicWorkflowNodeMetadata) Reset()

func (*DynamicWorkflowNodeMetadata) String 

func (x *DynamicWorkflowNodeMetadata) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// contains filtered or unexported fields
}

func (*EventReason) Descriptor deprecated 

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

Deprecated: Use EventReason.ProtoReflect.Descriptor instead.

func (*EventReason) GetOccurredAt 

func (x *EventReason) GetOccurredAt() *timestamppb.Timestamp

func (*EventReason) GetReason 

func (x *EventReason) GetReason() string

func (*EventReason) ProtoMessage 

func (*EventReason) ProtoMessage()

func (*EventReason) ProtoReflect added in v1.10.7 

func (x *EventReason) ProtoReflect() protoreflect.Message

func (*EventReason) Reset 

func (x *EventReason) Reset()

func (*EventReason) String 

func (x *EventReason) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*ExternalResourceInfo) Descriptor deprecated 

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

Deprecated: Use ExternalResourceInfo.ProtoReflect.Descriptor instead.

func (*ExternalResourceInfo) GetCacheStatus 

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

func (*ExternalResourceInfo) GetExternalId 

func (x *ExternalResourceInfo) GetExternalId() string

func (*ExternalResourceInfo) GetIndex 

func (x *ExternalResourceInfo) GetIndex() uint32

func (*ExternalResourceInfo) GetLogs 

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

func (*ExternalResourceInfo) GetPhase 

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

func (*ExternalResourceInfo) GetRetryAttempt 

func (x *ExternalResourceInfo) GetRetryAttempt() uint32

func (*ExternalResourceInfo) ProtoMessage 

func (*ExternalResourceInfo) ProtoMessage()

func (*ExternalResourceInfo) ProtoReflect added in v1.10.7 

func (x *ExternalResourceInfo) ProtoReflect() protoreflect.Message

func (*ExternalResourceInfo) Reset 

func (x *ExternalResourceInfo) Reset()

func (*ExternalResourceInfo) String 

func (x *ExternalResourceInfo) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are assignable to InputValue:
	//
	//	*NodeExecutionEvent_InputUri
	//	*NodeExecutionEvent_InputData
	InputValue isNodeExecutionEvent_InputValue `protobuf_oneof:"input_value"`
	// Types that are assignable 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 assignable 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 *timestamppb.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"`
	// contains filtered or unexported fields
}

func (*NodeExecutionEvent) Descriptor deprecated 

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

Deprecated: Use NodeExecutionEvent.ProtoReflect.Descriptor instead.

func (*NodeExecutionEvent) GetDeckUri 

func (x *NodeExecutionEvent) GetDeckUri() string

func (*NodeExecutionEvent) GetError 

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

func (*NodeExecutionEvent) GetEventVersion 

func (x *NodeExecutionEvent) GetEventVersion() int32

func (*NodeExecutionEvent) GetId 

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

func (*NodeExecutionEvent) GetInputData 

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

func (*NodeExecutionEvent) GetInputUri 

func (x *NodeExecutionEvent) GetInputUri() string

func (*NodeExecutionEvent) GetInputValue 

func (m *NodeExecutionEvent) GetInputValue() isNodeExecutionEvent_InputValue

func (*NodeExecutionEvent) GetIsArray added in v1.9.14 

func (x *NodeExecutionEvent) GetIsArray() bool

func (*NodeExecutionEvent) GetIsDynamic 

func (x *NodeExecutionEvent) GetIsDynamic() bool

func (*NodeExecutionEvent) GetIsParent 

func (x *NodeExecutionEvent) GetIsParent() bool

func (*NodeExecutionEvent) GetNodeName 

func (x *NodeExecutionEvent) GetNodeName() string

func (*NodeExecutionEvent) GetOccurredAt 

func (x *NodeExecutionEvent) GetOccurredAt() *timestamppb.Timestamp

func (*NodeExecutionEvent) GetOutputData 

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

func (*NodeExecutionEvent) GetOutputResult 

func (m *NodeExecutionEvent) GetOutputResult() isNodeExecutionEvent_OutputResult

func (*NodeExecutionEvent) GetOutputUri 

func (x *NodeExecutionEvent) GetOutputUri() string

func (*NodeExecutionEvent) GetParentNodeMetadata 

func (x *NodeExecutionEvent) GetParentNodeMetadata() *ParentNodeExecutionMetadata

func (*NodeExecutionEvent) GetParentTaskMetadata 

func (x *NodeExecutionEvent) GetParentTaskMetadata() *ParentTaskExecutionMetadata

func (*NodeExecutionEvent) GetPhase 

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

func (*NodeExecutionEvent) GetProducerId 

func (x *NodeExecutionEvent) GetProducerId() string

func (*NodeExecutionEvent) GetReportedAt 

func (x *NodeExecutionEvent) GetReportedAt() *timestamppb.Timestamp

func (*NodeExecutionEvent) GetRetryGroup 

func (x *NodeExecutionEvent) GetRetryGroup() string

func (*NodeExecutionEvent) GetSpecNodeId 

func (x *NodeExecutionEvent) GetSpecNodeId() string

func (*NodeExecutionEvent) GetTargetMetadata 

func (m *NodeExecutionEvent) GetTargetMetadata() isNodeExecutionEvent_TargetMetadata

func (*NodeExecutionEvent) GetTaskNodeMetadata 

func (x *NodeExecutionEvent) GetTaskNodeMetadata() *TaskNodeMetadata

func (*NodeExecutionEvent) GetWorkflowNodeMetadata 

func (x *NodeExecutionEvent) GetWorkflowNodeMetadata() *WorkflowNodeMetadata

func (*NodeExecutionEvent) ProtoMessage 

func (*NodeExecutionEvent) ProtoMessage()

func (*NodeExecutionEvent) ProtoReflect added in v1.10.7 

func (x *NodeExecutionEvent) ProtoReflect() protoreflect.Message

func (*NodeExecutionEvent) Reset 

func (x *NodeExecutionEvent) Reset()

func (*NodeExecutionEvent) String 

func (x *NodeExecutionEvent) String() string

type NodeExecutionEvent_Error 

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

type NodeExecutionEvent_InputData 

type NodeExecutionEvent_InputData struct {
	// Raw input data consumed by this node execution.
	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 {
	// Raw output data produced by this node execution.
	OutputData *core.LiteralMap `protobuf:"bytes,15,opt,name=output_data,json=outputData,proto3,oneof"`
}

type NodeExecutionEvent_OutputUri 

type NodeExecutionEvent_OutputUri struct {
	// URL to the output of the execution, it encodes all the information
	// including Cloud source provider. ie., s3://...
	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"`
	// contains filtered or unexported fields
}

func (*ParentNodeExecutionMetadata) Descriptor deprecated 

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

Deprecated: Use ParentNodeExecutionMetadata.ProtoReflect.Descriptor instead.

func (*ParentNodeExecutionMetadata) GetNodeId 

func (x *ParentNodeExecutionMetadata) GetNodeId() string

func (*ParentNodeExecutionMetadata) ProtoMessage 

func (*ParentNodeExecutionMetadata) ProtoMessage()

func (*ParentNodeExecutionMetadata) ProtoReflect added in v1.10.7 

func (x *ParentNodeExecutionMetadata) ProtoReflect() protoreflect.Message

func (*ParentNodeExecutionMetadata) Reset 

func (x *ParentNodeExecutionMetadata) Reset()

func (*ParentNodeExecutionMetadata) String 

func (x *ParentNodeExecutionMetadata) String() string

type ParentTaskExecutionMetadata 

type ParentTaskExecutionMetadata struct {
	Id *core.TaskExecutionIdentifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ParentTaskExecutionMetadata) Descriptor deprecated 

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

Deprecated: Use ParentTaskExecutionMetadata.ProtoReflect.Descriptor instead.

func (*ParentTaskExecutionMetadata) GetId 

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

func (*ParentTaskExecutionMetadata) ProtoMessage 

func (*ParentTaskExecutionMetadata) ProtoMessage()

func (*ParentTaskExecutionMetadata) ProtoReflect added in v1.10.7 

func (x *ParentTaskExecutionMetadata) ProtoReflect() protoreflect.Message

func (*ParentTaskExecutionMetadata) Reset 

func (x *ParentTaskExecutionMetadata) Reset()

func (*ParentTaskExecutionMetadata) String 

func (x *ParentTaskExecutionMetadata) String() string

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"`
	// contains filtered or unexported fields
}

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

func (*ResourcePoolInfo) Descriptor deprecated 

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

Deprecated: Use ResourcePoolInfo.ProtoReflect.Descriptor instead.

func (*ResourcePoolInfo) GetAllocationToken 

func (x *ResourcePoolInfo) GetAllocationToken() string

func (*ResourcePoolInfo) GetNamespace 

func (x *ResourcePoolInfo) GetNamespace() string

func (*ResourcePoolInfo) ProtoMessage 

func (*ResourcePoolInfo) ProtoMessage()

func (*ResourcePoolInfo) ProtoReflect added in v1.10.7 

func (x *ResourcePoolInfo) ProtoReflect() protoreflect.Message

func (*ResourcePoolInfo) Reset 

func (x *ResourcePoolInfo) Reset()

func (*ResourcePoolInfo) String 

func (x *ResourcePoolInfo) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are assignable to InputValue:
	//
	//	*TaskExecutionEvent_InputUri
	//	*TaskExecutionEvent_InputData
	InputValue isTaskExecutionEvent_InputValue `protobuf_oneof:"input_value"`
	// Types that are assignable 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 *structpb.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.
	//
	// Deprecated: Marked as deprecated in flyteidl/event/event.proto.
	Reason string `protobuf:"bytes,13,opt,name=reason,proto3" json:"reason,omitempty"`
	// 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 *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=reported_at,json=reportedAt,proto3" json:"reported_at,omitempty"`
	// contains filtered or unexported fields
}

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

func (*TaskExecutionEvent) Descriptor deprecated 

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

Deprecated: Use TaskExecutionEvent.ProtoReflect.Descriptor instead.

func (*TaskExecutionEvent) GetCustomInfo 

func (x *TaskExecutionEvent) GetCustomInfo() *structpb.Struct

func (*TaskExecutionEvent) GetError 

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

func (*TaskExecutionEvent) GetEventVersion 

func (x *TaskExecutionEvent) GetEventVersion() int32

func (*TaskExecutionEvent) GetInputData 

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

func (*TaskExecutionEvent) GetInputUri 

func (x *TaskExecutionEvent) GetInputUri() string

func (*TaskExecutionEvent) GetInputValue 

func (m *TaskExecutionEvent) GetInputValue() isTaskExecutionEvent_InputValue

func (*TaskExecutionEvent) GetLogs 

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

func (*TaskExecutionEvent) GetMetadata 

func (x *TaskExecutionEvent) GetMetadata() *TaskExecutionMetadata

func (*TaskExecutionEvent) GetOccurredAt 

func (x *TaskExecutionEvent) GetOccurredAt() *timestamppb.Timestamp

func (*TaskExecutionEvent) GetOutputData 

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

func (*TaskExecutionEvent) GetOutputResult 

func (m *TaskExecutionEvent) GetOutputResult() isTaskExecutionEvent_OutputResult

func (*TaskExecutionEvent) GetOutputUri 

func (x *TaskExecutionEvent) GetOutputUri() string

func (*TaskExecutionEvent) GetParentNodeExecutionId 

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

func (*TaskExecutionEvent) GetPhase 

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

func (*TaskExecutionEvent) GetPhaseVersion 

func (x *TaskExecutionEvent) GetPhaseVersion() uint32

func (*TaskExecutionEvent) GetProducerId 

func (x *TaskExecutionEvent) GetProducerId() string

func (*TaskExecutionEvent) GetReason deprecated 

func (x *TaskExecutionEvent) GetReason() string

Deprecated: Marked as deprecated in flyteidl/event/event.proto.

func (*TaskExecutionEvent) GetReasons 

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

func (*TaskExecutionEvent) GetReportedAt 

func (x *TaskExecutionEvent) GetReportedAt() *timestamppb.Timestamp

func (*TaskExecutionEvent) GetRetryAttempt 

func (x *TaskExecutionEvent) GetRetryAttempt() uint32

func (*TaskExecutionEvent) GetTaskId 

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

func (*TaskExecutionEvent) GetTaskType 

func (x *TaskExecutionEvent) GetTaskType() string

func (*TaskExecutionEvent) ProtoMessage 

func (*TaskExecutionEvent) ProtoMessage()

func (*TaskExecutionEvent) ProtoReflect added in v1.10.7 

func (x *TaskExecutionEvent) ProtoReflect() protoreflect.Message

func (*TaskExecutionEvent) Reset 

func (x *TaskExecutionEvent) Reset()

func (*TaskExecutionEvent) String 

func (x *TaskExecutionEvent) String() string

type TaskExecutionEvent_Error 

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

type TaskExecutionEvent_InputData 

type TaskExecutionEvent_InputData struct {
	// Raw input data consumed by this task execution.
	InputData *core.LiteralMap `protobuf:"bytes,19,opt,name=input_data,json=inputData,proto3,oneof"`
}

type TaskExecutionEvent_InputUri 

type TaskExecutionEvent_InputUri struct {
	// 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,oneof"`
}

type TaskExecutionEvent_OutputData 

type TaskExecutionEvent_OutputData struct {
	// Raw output data produced by this task execution.
	OutputData *core.LiteralMap `protobuf:"bytes,17,opt,name=output_data,json=outputData,proto3,oneof"`
}

type TaskExecutionEvent_OutputUri 

type TaskExecutionEvent_OutputUri struct {
	// URI to the output of the execution, it will be in a format that encodes all the information
	// including Cloud source provider. ie., s3://...
	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 */
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use TaskExecutionMetadata.ProtoReflect.Descriptor instead.

func (*TaskExecutionMetadata) GetExternalResources 

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

func (*TaskExecutionMetadata) GetGeneratedName 

func (x *TaskExecutionMetadata) GetGeneratedName() string

func (*TaskExecutionMetadata) GetInstanceClass 

func (x *TaskExecutionMetadata) GetInstanceClass() TaskExecutionMetadata_InstanceClass

func (*TaskExecutionMetadata) GetPluginIdentifier 

func (x *TaskExecutionMetadata) GetPluginIdentifier() string

func (*TaskExecutionMetadata) GetResourcePoolInfo 

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

func (*TaskExecutionMetadata) ProtoMessage 

func (*TaskExecutionMetadata) ProtoMessage()

func (*TaskExecutionMetadata) ProtoReflect added in v1.10.7 

func (x *TaskExecutionMetadata) ProtoReflect() protoreflect.Message

func (*TaskExecutionMetadata) Reset 

func (x *TaskExecutionMetadata) Reset()

func (*TaskExecutionMetadata) String 

func (x *TaskExecutionMetadata) String() string

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) Descriptor added in v1.10.7 

func (TaskExecutionMetadata_InstanceClass) Descriptor() protoreflect.EnumDescriptor

func (TaskExecutionMetadata_InstanceClass) Enum added in v1.10.7 

func (x TaskExecutionMetadata_InstanceClass) Enum() *TaskExecutionMetadata_InstanceClass

func (TaskExecutionMetadata_InstanceClass) EnumDescriptor deprecated 

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

Deprecated: Use TaskExecutionMetadata_InstanceClass.Descriptor instead.

func (TaskExecutionMetadata_InstanceClass) Number added in v1.10.7 

func (x TaskExecutionMetadata_InstanceClass) Number() protoreflect.EnumNumber

func (TaskExecutionMetadata_InstanceClass) String 

func (x TaskExecutionMetadata_InstanceClass) String() string

func (TaskExecutionMetadata_InstanceClass) Type added in v1.10.7 

func (TaskExecutionMetadata_InstanceClass) Type() protoreflect.EnumType

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"`
	// contains filtered or unexported fields
}

func (*TaskNodeMetadata) Descriptor deprecated 

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

Deprecated: Use TaskNodeMetadata.ProtoReflect.Descriptor instead.

func (*TaskNodeMetadata) GetCacheStatus 

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

func (*TaskNodeMetadata) GetCatalogKey 

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

func (*TaskNodeMetadata) GetCheckpointUri 

func (x *TaskNodeMetadata) GetCheckpointUri() string

func (*TaskNodeMetadata) GetDynamicWorkflow 

func (x *TaskNodeMetadata) GetDynamicWorkflow() *DynamicWorkflowNodeMetadata

func (*TaskNodeMetadata) GetReservationStatus 

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

func (*TaskNodeMetadata) ProtoMessage 

func (*TaskNodeMetadata) ProtoMessage()

func (*TaskNodeMetadata) ProtoReflect added in v1.10.7 

func (x *TaskNodeMetadata) ProtoReflect() protoreflect.Message

func (*TaskNodeMetadata) Reset 

func (x *TaskNodeMetadata) Reset()

func (*TaskNodeMetadata) String 

func (x *TaskNodeMetadata) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// Types that are assignable to OutputResult:
	//
	//	*WorkflowExecutionEvent_OutputUri
	//	*WorkflowExecutionEvent_Error
	//	*WorkflowExecutionEvent_OutputData
	OutputResult isWorkflowExecutionEvent_OutputResult `protobuf_oneof:"output_result"`
	// contains filtered or unexported fields
}

func (*WorkflowExecutionEvent) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionEvent.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionEvent) GetError 

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

func (*WorkflowExecutionEvent) GetExecutionId 

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

func (*WorkflowExecutionEvent) GetOccurredAt 

func (x *WorkflowExecutionEvent) GetOccurredAt() *timestamppb.Timestamp

func (*WorkflowExecutionEvent) GetOutputData 

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

func (*WorkflowExecutionEvent) GetOutputResult 

func (m *WorkflowExecutionEvent) GetOutputResult() isWorkflowExecutionEvent_OutputResult

func (*WorkflowExecutionEvent) GetOutputUri 

func (x *WorkflowExecutionEvent) GetOutputUri() string

func (*WorkflowExecutionEvent) GetPhase 

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

func (*WorkflowExecutionEvent) GetProducerId 

func (x *WorkflowExecutionEvent) GetProducerId() string

func (*WorkflowExecutionEvent) ProtoMessage 

func (*WorkflowExecutionEvent) ProtoMessage()

func (*WorkflowExecutionEvent) ProtoReflect added in v1.10.7 

func (x *WorkflowExecutionEvent) ProtoReflect() protoreflect.Message

func (*WorkflowExecutionEvent) Reset 

func (x *WorkflowExecutionEvent) Reset()

func (*WorkflowExecutionEvent) String 

func (x *WorkflowExecutionEvent) String() string

type WorkflowExecutionEvent_Error 

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

type WorkflowExecutionEvent_OutputData 

type WorkflowExecutionEvent_OutputData struct {
	// Raw output data produced by this workflow execution.
	OutputData *core.LiteralMap `protobuf:"bytes,7,opt,name=output_data,json=outputData,proto3,oneof"`
}

type WorkflowExecutionEvent_OutputUri 

type WorkflowExecutionEvent_OutputUri struct {
	// URL to the output of the execution, it encodes all the information
	// including Cloud source provider. ie., s3://...
	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"`
	// contains filtered or unexported fields
}

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

func (*WorkflowNodeMetadata) Descriptor deprecated 

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

Deprecated: Use WorkflowNodeMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowNodeMetadata) GetExecutionId 

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

func (*WorkflowNodeMetadata) ProtoMessage 

func (*WorkflowNodeMetadata) ProtoMessage()

func (*WorkflowNodeMetadata) ProtoReflect added in v1.10.7 

func (x *WorkflowNodeMetadata) ProtoReflect() protoreflect.Message

func (*WorkflowNodeMetadata) Reset 

func (x *WorkflowNodeMetadata) Reset()

func (*WorkflowNodeMetadata) String 

func (x *WorkflowNodeMetadata) String() string

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.