core

package
v1.11.1-b1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Granularity_name = map[int32]string{
		0: "UNSET",
		1: "MINUTE",
		2: "HOUR",
		3: "DAY",
		4: "MONTH",
	}
	Granularity_value = map[string]int32{
		"UNSET":  0,
		"MINUTE": 1,
		"HOUR":   2,
		"DAY":    3,
		"MONTH":  4,
	}
)

Enum value maps for Granularity.

View Source 
var (
	Operator_name = map[int32]string{
		0: "MINUS",
		1: "PLUS",
	}
	Operator_value = map[string]int32{
		"MINUS": 0,
		"PLUS":  1,
	}
)

Enum value maps for Operator.

View Source 
var (
	CatalogCacheStatus_name = map[int32]string{
		0: "CACHE_DISABLED",
		1: "CACHE_MISS",
		2: "CACHE_HIT",
		3: "CACHE_POPULATED",
		4: "CACHE_LOOKUP_FAILURE",
		5: "CACHE_PUT_FAILURE",
		6: "CACHE_SKIPPED",
		7: "CACHE_EVICTED",
	}
	CatalogCacheStatus_value = map[string]int32{
		"CACHE_DISABLED":       0,
		"CACHE_MISS":           1,
		"CACHE_HIT":            2,
		"CACHE_POPULATED":      3,
		"CACHE_LOOKUP_FAILURE": 4,
		"CACHE_PUT_FAILURE":    5,
		"CACHE_SKIPPED":        6,
		"CACHE_EVICTED":        7,
	}
)

Enum value maps for CatalogCacheStatus.

View Source 
var (
	CatalogReservation_Status_name = map[int32]string{
		0: "RESERVATION_DISABLED",
		1: "RESERVATION_ACQUIRED",
		2: "RESERVATION_EXISTS",
		3: "RESERVATION_RELEASED",
		4: "RESERVATION_FAILURE",
	}
	CatalogReservation_Status_value = map[string]int32{
		"RESERVATION_DISABLED": 0,
		"RESERVATION_ACQUIRED": 1,
		"RESERVATION_EXISTS":   2,
		"RESERVATION_RELEASED": 3,
		"RESERVATION_FAILURE":  4,
	}
)

Enum value maps for CatalogReservation_Status.

View Source 
var (
	ComparisonExpression_Operator_name = map[int32]string{
		0: "EQ",
		1: "NEQ",
		2: "GT",
		3: "GTE",
		4: "LT",
		5: "LTE",
	}
	ComparisonExpression_Operator_value = map[string]int32{
		"EQ":  0,
		"NEQ": 1,
		"GT":  2,
		"GTE": 3,
		"LT":  4,
		"LTE": 5,
	}
)

Enum value maps for ComparisonExpression_Operator.

View Source 
var (
	ConjunctionExpression_LogicalOperator_name = map[int32]string{
		0: "AND",
		1: "OR",
	}
	ConjunctionExpression_LogicalOperator_value = map[string]int32{
		"AND": 0,
		"OR":  1,
	}
)

Enum value maps for ConjunctionExpression_LogicalOperator.

View Source 
var (
	ContainerError_Kind_name = map[int32]string{
		0: "NON_RECOVERABLE",
		1: "RECOVERABLE",
	}
	ContainerError_Kind_value = map[string]int32{
		"NON_RECOVERABLE": 0,
		"RECOVERABLE":     1,
	}
)

Enum value maps for ContainerError_Kind.

View Source 
var (
	WorkflowExecution_Phase_name = map[int32]string{
		0: "UNDEFINED",
		1: "QUEUED",
		2: "RUNNING",
		3: "SUCCEEDING",
		4: "SUCCEEDED",
		5: "FAILING",
		6: "FAILED",
		7: "ABORTED",
		8: "TIMED_OUT",
		9: "ABORTING",
	}
	WorkflowExecution_Phase_value = map[string]int32{
		"UNDEFINED":  0,
		"QUEUED":     1,
		"RUNNING":    2,
		"SUCCEEDING": 3,
		"SUCCEEDED":  4,
		"FAILING":    5,
		"FAILED":     6,
		"ABORTED":    7,
		"TIMED_OUT":  8,
		"ABORTING":   9,
	}
)

Enum value maps for WorkflowExecution_Phase.

View Source 
var (
	NodeExecution_Phase_name = map[int32]string{
		0:  "UNDEFINED",
		1:  "QUEUED",
		2:  "RUNNING",
		3:  "SUCCEEDED",
		4:  "FAILING",
		5:  "FAILED",
		6:  "ABORTED",
		7:  "SKIPPED",
		8:  "TIMED_OUT",
		9:  "DYNAMIC_RUNNING",
		10: "RECOVERED",
	}
	NodeExecution_Phase_value = map[string]int32{
		"UNDEFINED":       0,
		"QUEUED":          1,
		"RUNNING":         2,
		"SUCCEEDED":       3,
		"FAILING":         4,
		"FAILED":          5,
		"ABORTED":         6,
		"SKIPPED":         7,
		"TIMED_OUT":       8,
		"DYNAMIC_RUNNING": 9,
		"RECOVERED":       10,
	}
)

Enum value maps for NodeExecution_Phase.

View Source 
var (
	TaskExecution_Phase_name = map[int32]string{
		0: "UNDEFINED",
		1: "QUEUED",
		2: "RUNNING",
		3: "SUCCEEDED",
		4: "ABORTED",
		5: "FAILED",
		6: "INITIALIZING",
		7: "WAITING_FOR_RESOURCES",
	}
	TaskExecution_Phase_value = map[string]int32{
		"UNDEFINED":             0,
		"QUEUED":                1,
		"RUNNING":               2,
		"SUCCEEDED":             3,
		"ABORTED":               4,
		"FAILED":                5,
		"INITIALIZING":          6,
		"WAITING_FOR_RESOURCES": 7,
	}
)

Enum value maps for TaskExecution_Phase.

View Source 
var (
	ExecutionError_ErrorKind_name = map[int32]string{
		0: "UNKNOWN",
		1: "USER",
		2: "SYSTEM",
	}
	ExecutionError_ErrorKind_value = map[string]int32{
		"UNKNOWN": 0,
		"USER":    1,
		"SYSTEM":  2,
	}
)

Enum value maps for ExecutionError_ErrorKind.

View Source 
var (
	TaskLog_MessageFormat_name = map[int32]string{
		0: "UNKNOWN",
		1: "CSV",
		2: "JSON",
	}
	TaskLog_MessageFormat_value = map[string]int32{
		"UNKNOWN": 0,
		"CSV":     1,
		"JSON":    2,
	}
)

Enum value maps for TaskLog_MessageFormat.

View Source 
var (
	QualityOfService_Tier_name = map[int32]string{
		0: "UNDEFINED",
		1: "HIGH",
		2: "MEDIUM",
		3: "LOW",
	}
	QualityOfService_Tier_value = map[string]int32{
		"UNDEFINED": 0,
		"HIGH":      1,
		"MEDIUM":    2,
		"LOW":       3,
	}
)

Enum value maps for QualityOfService_Tier.

View Source 
var (
	ResourceType_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "TASK",
		2: "WORKFLOW",
		3: "LAUNCH_PLAN",
		4: "DATASET",
	}
	ResourceType_value = map[string]int32{
		"UNSPECIFIED": 0,
		"TASK":        1,
		"WORKFLOW":    2,
		"LAUNCH_PLAN": 3,
		"DATASET":     4,
	}
)

Enum value maps for ResourceType.

View Source 
var (
	Secret_MountType_name = map[int32]string{
		0: "ANY",
		1: "ENV_VAR",
		2: "FILE",
	}
	Secret_MountType_value = map[string]int32{
		"ANY":     0,
		"ENV_VAR": 1,
		"FILE":    2,
	}
)

Enum value maps for Secret_MountType.

View Source 
var (
	OAuth2TokenRequest_Type_name = map[int32]string{
		0: "CLIENT_CREDENTIALS",
	}
	OAuth2TokenRequest_Type_value = map[string]int32{
		"CLIENT_CREDENTIALS": 0,
	}
)

Enum value maps for OAuth2TokenRequest_Type.

View Source 
var (
	Resources_ResourceName_name = map[int32]string{
		0: "UNKNOWN",
		1: "CPU",
		2: "GPU",
		3: "MEMORY",
		4: "STORAGE",
		5: "EPHEMERAL_STORAGE",
	}
	Resources_ResourceName_value = map[string]int32{
		"UNKNOWN":           0,
		"CPU":               1,
		"GPU":               2,
		"MEMORY":            3,
		"STORAGE":           4,
		"EPHEMERAL_STORAGE": 5,
	}
)

Enum value maps for Resources_ResourceName.

View Source 
var (
	RuntimeMetadata_RuntimeType_name = map[int32]string{
		0: "OTHER",
		1: "FLYTE_SDK",
	}
	RuntimeMetadata_RuntimeType_value = map[string]int32{
		"OTHER":     0,
		"FLYTE_SDK": 1,
	}
)

Enum value maps for RuntimeMetadata_RuntimeType.

View Source 
var (
	Container_Architecture_name = map[int32]string{
		0: "UNKNOWN",
		1: "AMD64",
		2: "ARM64",
		3: "ARM_V6",
		4: "ARM_V7",
	}
	Container_Architecture_value = map[string]int32{
		"UNKNOWN": 0,
		"AMD64":   1,
		"ARM64":   2,
		"ARM_V6":  3,
		"ARM_V7":  4,
	}
)

Enum value maps for Container_Architecture.

View Source 
var (
	IOStrategy_DownloadMode_name = map[int32]string{
		0: "DOWNLOAD_EAGER",
		1: "DOWNLOAD_STREAM",
		2: "DO_NOT_DOWNLOAD",
	}
	IOStrategy_DownloadMode_value = map[string]int32{
		"DOWNLOAD_EAGER":  0,
		"DOWNLOAD_STREAM": 1,
		"DO_NOT_DOWNLOAD": 2,
	}
)

Enum value maps for IOStrategy_DownloadMode.

View Source 
var (
	IOStrategy_UploadMode_name = map[int32]string{
		0: "UPLOAD_ON_EXIT",
		1: "UPLOAD_EAGER",
		2: "DO_NOT_UPLOAD",
	}
	IOStrategy_UploadMode_value = map[string]int32{
		"UPLOAD_ON_EXIT": 0,
		"UPLOAD_EAGER":   1,
		"DO_NOT_UPLOAD":  2,
	}
)

Enum value maps for IOStrategy_UploadMode.

View Source 
var (
	DataLoadingConfig_LiteralMapFormat_name = map[int32]string{
		0: "JSON",
		1: "YAML",
		2: "PROTO",
	}
	DataLoadingConfig_LiteralMapFormat_value = map[string]int32{
		"JSON":  0,
		"YAML":  1,
		"PROTO": 2,
	}
)

Enum value maps for DataLoadingConfig_LiteralMapFormat.

View Source 
var (
	Sql_Dialect_name = map[int32]string{
		0: "UNDEFINED",
		1: "ANSI",
		2: "HIVE",
		3: "OTHER",
	}
	Sql_Dialect_value = map[string]int32{
		"UNDEFINED": 0,
		"ANSI":      1,
		"HIVE":      2,
		"OTHER":     3,
	}
)

Enum value maps for Sql_Dialect.

View Source 
var (
	SimpleType_name = map[int32]string{
		0: "NONE",
		1: "INTEGER",
		2: "FLOAT",
		3: "STRING",
		4: "BOOLEAN",
		5: "DATETIME",
		6: "DURATION",
		7: "BINARY",
		8: "ERROR",
		9: "STRUCT",
	}
	SimpleType_value = map[string]int32{
		"NONE":     0,
		"INTEGER":  1,
		"FLOAT":    2,
		"STRING":   3,
		"BOOLEAN":  4,
		"DATETIME": 5,
		"DURATION": 6,
		"BINARY":   7,
		"ERROR":    8,
		"STRUCT":   9,
	}
)

Enum value maps for SimpleType.

View Source 
var (
	SchemaType_SchemaColumn_SchemaColumnType_name = map[int32]string{
		0: "INTEGER",
		1: "FLOAT",
		2: "STRING",
		3: "BOOLEAN",
		4: "DATETIME",
		5: "DURATION",
	}
	SchemaType_SchemaColumn_SchemaColumnType_value = map[string]int32{
		"INTEGER":  0,
		"FLOAT":    1,
		"STRING":   2,
		"BOOLEAN":  3,
		"DATETIME": 4,
		"DURATION": 5,
	}
)

Enum value maps for SchemaType_SchemaColumn_SchemaColumnType.

View Source 
var (
	BlobType_BlobDimensionality_name = map[int32]string{
		0: "SINGLE",
		1: "MULTIPART",
	}
	BlobType_BlobDimensionality_value = map[string]int32{
		"SINGLE":    0,
		"MULTIPART": 1,
	}
)

Enum value maps for BlobType_BlobDimensionality.

View Source 
var (
	WorkflowMetadata_OnFailurePolicy_name = map[int32]string{
		0: "FAIL_IMMEDIATELY",
		1: "FAIL_AFTER_EXECUTABLE_NODES_COMPLETE",
	}
	WorkflowMetadata_OnFailurePolicy_value = map[string]int32{
		"FAIL_IMMEDIATELY":                     0,
		"FAIL_AFTER_EXECUTABLE_NODES_COMPLETE": 1,
	}
)

Enum value maps for WorkflowMetadata_OnFailurePolicy.

View Source 
var File_flyteidl_core_artifact_id_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_catalog_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_compiler_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_condition_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_dynamic_job_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_errors_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_execution_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_identifier_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_interface_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_literals_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_metrics_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_security_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_tasks_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_types_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_workflow_closure_proto protoreflect.FileDescriptor
View Source 
var File_flyteidl_core_workflow_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Alias 

type Alias struct {

	// Must match one of the output variable names on a node.
	Var string `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// A workflow-level unique alias that downstream nodes can refer to in their input.
	Alias string `protobuf:"bytes,2,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

Links a variable to an alias.

func (*Alias) Descriptor deprecated 

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

Deprecated: Use Alias.ProtoReflect.Descriptor instead.

func (*Alias) GetAlias 

func (x *Alias) GetAlias() string

func (*Alias) GetVar 

func (x *Alias) GetVar() string

func (*Alias) ProtoMessage 

func (*Alias) ProtoMessage()

func (*Alias) ProtoReflect added in v1.10.7 

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

func (*Alias) Reset 

func (x *Alias) Reset()

func (*Alias) String 

func (x *Alias) String() string

type ApproveCondition 

type ApproveCondition struct {

	// A unique identifier for the requested boolean signal.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// contains filtered or unexported fields
}

ApproveCondition represents a dependency on an external approval. During execution, this will manifest as a boolean signal with the provided signal_id.

func (*ApproveCondition) Descriptor deprecated 

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

Deprecated: Use ApproveCondition.ProtoReflect.Descriptor instead.

func (*ApproveCondition) GetSignalId 

func (x *ApproveCondition) GetSignalId() string

func (*ApproveCondition) ProtoMessage 

func (*ApproveCondition) ProtoMessage()

func (*ApproveCondition) ProtoReflect added in v1.10.7 

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

func (*ApproveCondition) Reset 

func (x *ApproveCondition) Reset()

func (*ApproveCondition) String 

func (x *ApproveCondition) String() string

type ArrayNode 

type ArrayNode struct {

	// node is the sub-node that will be executed for each element in the array.
	Node *Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	// parallelism defines the minimum number of instances to bring up concurrently at any given
	// point. Note that this is an optimistic restriction and that, due to network partitioning or
	// other failures, the actual number of currently running instances might be more. This has to
	// be a positive number if assigned. Default value is size.
	Parallelism uint32 `protobuf:"varint,2,opt,name=parallelism,proto3" json:"parallelism,omitempty"`
	// Types that are assignable to SuccessCriteria:
	//
	//	*ArrayNode_MinSuccesses
	//	*ArrayNode_MinSuccessRatio
	SuccessCriteria isArrayNode_SuccessCriteria `protobuf_oneof:"success_criteria"`
	// contains filtered or unexported fields
}

ArrayNode is a Flyte node type that simplifies the execution of a sub-node over a list of input values. An ArrayNode can be executed with configurable parallelism (separate from the parent workflow) and can be configured to succeed when a certain number of sub-nodes succeed.

func (*ArrayNode) Descriptor deprecated 

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

Deprecated: Use ArrayNode.ProtoReflect.Descriptor instead.

func (*ArrayNode) GetMinSuccessRatio 

func (x *ArrayNode) GetMinSuccessRatio() float32

func (*ArrayNode) GetMinSuccesses 

func (x *ArrayNode) GetMinSuccesses() uint32

func (*ArrayNode) GetNode 

func (x *ArrayNode) GetNode() *Node

func (*ArrayNode) GetParallelism 

func (x *ArrayNode) GetParallelism() uint32

func (*ArrayNode) GetSuccessCriteria 

func (m *ArrayNode) GetSuccessCriteria() isArrayNode_SuccessCriteria

func (*ArrayNode) ProtoMessage 

func (*ArrayNode) ProtoMessage()

func (*ArrayNode) ProtoReflect added in v1.10.7 

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

func (*ArrayNode) Reset 

func (x *ArrayNode) Reset()

func (*ArrayNode) String 

func (x *ArrayNode) String() string

type ArrayNode_MinSuccessRatio 

type ArrayNode_MinSuccessRatio struct {
	// If the array job size is not known beforehand, the min_success_ratio can instead be used
	// to determine when an ArrayNode can be marked successful.
	MinSuccessRatio float32 `protobuf:"fixed32,4,opt,name=min_success_ratio,json=minSuccessRatio,proto3,oneof"`
}

type ArrayNode_MinSuccesses 

type ArrayNode_MinSuccesses struct {
	// min_successes is an absolute number of the minimum number of successful completions of
	// sub-nodes. As soon as this criteria is met, the ArrayNode will be marked as successful
	// and outputs will be computed. This has to be a non-negative number if assigned. Default
	// value is size (if specified).
	MinSuccesses uint32 `protobuf:"varint,3,opt,name=min_successes,json=minSuccesses,proto3,oneof"`
}

type ArtifactBindingData added in v1.10.7 

type ArtifactBindingData struct {

	// These two fields are only relevant in the partition value case
	//
	// Types that are assignable to PartitionData:
	//
	//	*ArtifactBindingData_PartitionKey
	//	*ArtifactBindingData_BindToTimePartition
	PartitionData isArtifactBindingData_PartitionData `protobuf_oneof:"partition_data"`
	// This is only relevant in the time partition case
	TimeTransform *TimeTransform `protobuf:"bytes,7,opt,name=time_transform,json=timeTransform,proto3" json:"time_transform,omitempty"`
	// contains filtered or unexported fields
}

Only valid for triggers

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

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

Deprecated: Use ArtifactBindingData.ProtoReflect.Descriptor instead.

func (*ArtifactBindingData) GetBindToTimePartition added in v1.10.7 

func (x *ArtifactBindingData) GetBindToTimePartition() bool

func (*ArtifactBindingData) GetPartitionData added in v1.10.7 

func (m *ArtifactBindingData) GetPartitionData() isArtifactBindingData_PartitionData

func (*ArtifactBindingData) GetPartitionKey added in v1.10.7 

func (x *ArtifactBindingData) GetPartitionKey() string

func (*ArtifactBindingData) GetTimeTransform added in v1.11.0 

func (x *ArtifactBindingData) GetTimeTransform() *TimeTransform

func (*ArtifactBindingData) ProtoMessage added in v1.10.7 

func (*ArtifactBindingData) ProtoMessage()

func (*ArtifactBindingData) ProtoReflect added in v1.10.7 

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

func (*ArtifactBindingData) Reset added in v1.10.7 

func (x *ArtifactBindingData) Reset()

func (*ArtifactBindingData) String added in v1.10.7 

func (x *ArtifactBindingData) String() string

type ArtifactBindingData_BindToTimePartition added in v1.10.7 

type ArtifactBindingData_BindToTimePartition struct {
	BindToTimePartition bool `protobuf:"varint,6,opt,name=bind_to_time_partition,json=bindToTimePartition,proto3,oneof"`
}

type ArtifactBindingData_PartitionKey added in v1.10.7 

type ArtifactBindingData_PartitionKey struct {
	PartitionKey string `protobuf:"bytes,5,opt,name=partition_key,json=partitionKey,proto3,oneof"`
}

type ArtifactID added in v1.10.7 

type ArtifactID struct {
	ArtifactKey *ArtifactKey `protobuf:"bytes,1,opt,name=artifact_key,json=artifactKey,proto3" json:"artifact_key,omitempty"`
	Version     string       `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Think of a partition as a tag on an Artifact, except it's a key-value pair.
	// Different partitions naturally have different versions (execution ids).
	Partitions *Partitions `protobuf:"bytes,3,opt,name=partitions,proto3" json:"partitions,omitempty"`
	// There is no such thing as an empty time partition - if it's not set, then there is no time partition.
	TimePartition *TimePartition `protobuf:"bytes,4,opt,name=time_partition,json=timePartition,proto3" json:"time_partition,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ArtifactID.ProtoReflect.Descriptor instead.

func (*ArtifactID) GetArtifactKey added in v1.10.7 

func (x *ArtifactID) GetArtifactKey() *ArtifactKey

func (*ArtifactID) GetPartitions added in v1.10.7 

func (x *ArtifactID) GetPartitions() *Partitions

func (*ArtifactID) GetTimePartition added in v1.10.7 

func (x *ArtifactID) GetTimePartition() *TimePartition

func (*ArtifactID) GetVersion added in v1.10.7 

func (x *ArtifactID) GetVersion() string

func (*ArtifactID) ProtoMessage added in v1.10.7 

func (*ArtifactID) ProtoMessage()

func (*ArtifactID) ProtoReflect added in v1.10.7 

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

func (*ArtifactID) Reset added in v1.10.7 

func (x *ArtifactID) Reset()

func (*ArtifactID) String added in v1.10.7 

func (x *ArtifactID) String() string

type ArtifactKey added in v1.10.7 

type ArtifactKey struct {

	// Project and domain and suffix needs to be unique across a given artifact store.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Domain  string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	Name    string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Org     string `protobuf:"bytes,4,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ArtifactKey.ProtoReflect.Descriptor instead.

func (*ArtifactKey) GetDomain added in v1.10.7 

func (x *ArtifactKey) GetDomain() string

func (*ArtifactKey) GetName added in v1.10.7 

func (x *ArtifactKey) GetName() string

func (*ArtifactKey) GetOrg added in v1.11.0 

func (x *ArtifactKey) GetOrg() string

func (*ArtifactKey) GetProject added in v1.10.7 

func (x *ArtifactKey) GetProject() string

func (*ArtifactKey) ProtoMessage added in v1.10.7 

func (*ArtifactKey) ProtoMessage()

func (*ArtifactKey) ProtoReflect added in v1.10.7 

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

func (*ArtifactKey) Reset added in v1.10.7 

func (x *ArtifactKey) Reset()

func (*ArtifactKey) String added in v1.10.7 

func (x *ArtifactKey) String() string

type ArtifactQuery added in v1.10.7 

type ArtifactQuery struct {

	// Types that are assignable to Identifier:
	//
	//	*ArtifactQuery_ArtifactId
	//	*ArtifactQuery_ArtifactTag
	//	*ArtifactQuery_Uri
	//	*ArtifactQuery_Binding
	Identifier isArtifactQuery_Identifier `protobuf_oneof:"identifier"`
	// contains filtered or unexported fields
}

Uniqueness constraints for Artifacts

  • project, domain, name, version, partitions

Option 2 (tags are standalone, point to an individual artifact id):

  • project, domain, name, alias (points to one partition if partitioned)
  • project, domain, name, partition key, partition value

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

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

Deprecated: Use ArtifactQuery.ProtoReflect.Descriptor instead.

func (*ArtifactQuery) GetArtifactId added in v1.10.7 

func (x *ArtifactQuery) GetArtifactId() *ArtifactID

func (*ArtifactQuery) GetArtifactTag added in v1.10.7 

func (x *ArtifactQuery) GetArtifactTag() *ArtifactTag

func (*ArtifactQuery) GetBinding added in v1.10.7 

func (x *ArtifactQuery) GetBinding() *ArtifactBindingData

func (*ArtifactQuery) GetIdentifier added in v1.10.7 

func (m *ArtifactQuery) GetIdentifier() isArtifactQuery_Identifier

func (*ArtifactQuery) GetUri added in v1.10.7 

func (x *ArtifactQuery) GetUri() string

func (*ArtifactQuery) ProtoMessage added in v1.10.7 

func (*ArtifactQuery) ProtoMessage()

func (*ArtifactQuery) ProtoReflect added in v1.10.7 

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

func (*ArtifactQuery) Reset added in v1.10.7 

func (x *ArtifactQuery) Reset()

func (*ArtifactQuery) String added in v1.10.7 

func (x *ArtifactQuery) String() string

type ArtifactQuery_ArtifactId added in v1.10.7 

type ArtifactQuery_ArtifactId struct {
	ArtifactId *ArtifactID `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type ArtifactQuery_ArtifactTag added in v1.10.7 

type ArtifactQuery_ArtifactTag struct {
	ArtifactTag *ArtifactTag `protobuf:"bytes,2,opt,name=artifact_tag,json=artifactTag,proto3,oneof"`
}

type ArtifactQuery_Binding added in v1.10.7 

type ArtifactQuery_Binding struct {
	// This is used in the trigger case, where a user specifies a value for an input that is one of the triggering
	// artifacts, or a partition value derived from a triggering artifact.
	Binding *ArtifactBindingData `protobuf:"bytes,4,opt,name=binding,proto3,oneof"`
}

type ArtifactQuery_Uri added in v1.10.7 

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

type ArtifactTag added in v1.10.7 

type ArtifactTag struct {
	ArtifactKey *ArtifactKey `protobuf:"bytes,1,opt,name=artifact_key,json=artifactKey,proto3" json:"artifact_key,omitempty"`
	Value       *LabelValue  `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use ArtifactTag.ProtoReflect.Descriptor instead.

func (*ArtifactTag) GetArtifactKey added in v1.10.7 

func (x *ArtifactTag) GetArtifactKey() *ArtifactKey

func (*ArtifactTag) GetValue added in v1.10.7 

func (x *ArtifactTag) GetValue() *LabelValue

func (*ArtifactTag) ProtoMessage added in v1.10.7 

func (*ArtifactTag) ProtoMessage()

func (*ArtifactTag) ProtoReflect added in v1.10.7 

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

func (*ArtifactTag) Reset added in v1.10.7 

func (x *ArtifactTag) Reset()

func (*ArtifactTag) String added in v1.10.7 

func (x *ArtifactTag) String() string

type Binary 

type Binary struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Tag   string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// contains filtered or unexported fields
}

A simple byte array with a tag to help different parts of the system communicate about what is in the byte array. It's strongly advisable that consumers of this type define a unique tag and validate the tag before parsing the data.

func (*Binary) Descriptor deprecated 

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

Deprecated: Use Binary.ProtoReflect.Descriptor instead.

func (*Binary) GetTag 

func (x *Binary) GetTag() string

func (*Binary) GetValue 

func (x *Binary) GetValue() []byte

func (*Binary) ProtoMessage 

func (*Binary) ProtoMessage()

func (*Binary) ProtoReflect added in v1.10.7 

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

func (*Binary) Reset 

func (x *Binary) Reset()

func (*Binary) String 

func (x *Binary) String() string

type Binding 

type Binding struct {

	// Variable name must match an input/output variable of the node.
	Var string `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// Data to use to bind this variable.
	Binding *BindingData `protobuf:"bytes,2,opt,name=binding,proto3" json:"binding,omitempty"`
	// contains filtered or unexported fields
}

An input/output binding of a variable to either static value or a node output.

func (*Binding) Descriptor deprecated 

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

Deprecated: Use Binding.ProtoReflect.Descriptor instead.

func (*Binding) GetBinding 

func (x *Binding) GetBinding() *BindingData

func (*Binding) GetVar 

func (x *Binding) GetVar() string

func (*Binding) ProtoMessage 

func (*Binding) ProtoMessage()

func (*Binding) ProtoReflect added in v1.10.7 

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

func (*Binding) Reset 

func (x *Binding) Reset()

func (*Binding) String 

func (x *Binding) String() string

type BindingData 

type BindingData struct {

	// Types that are assignable to Value:
	//
	//	*BindingData_Scalar
	//	*BindingData_Collection
	//	*BindingData_Promise
	//	*BindingData_Map
	Value isBindingData_Value `protobuf_oneof:"value"`
	Union *UnionInfo          `protobuf:"bytes,5,opt,name=union,proto3" json:"union,omitempty"`
	// contains filtered or unexported fields
}

Specifies either a simple value or a reference to another output.

func (*BindingData) Descriptor deprecated 

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

Deprecated: Use BindingData.ProtoReflect.Descriptor instead.

func (*BindingData) GetCollection 

func (x *BindingData) GetCollection() *BindingDataCollection

func (*BindingData) GetMap 

func (x *BindingData) GetMap() *BindingDataMap

func (*BindingData) GetPromise 

func (x *BindingData) GetPromise() *OutputReference

func (*BindingData) GetScalar 

func (x *BindingData) GetScalar() *Scalar

func (*BindingData) GetUnion 

func (x *BindingData) GetUnion() *UnionInfo

func (*BindingData) GetValue 

func (m *BindingData) GetValue() isBindingData_Value

func (*BindingData) ProtoMessage 

func (*BindingData) ProtoMessage()

func (*BindingData) ProtoReflect added in v1.10.7 

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

func (*BindingData) Reset 

func (x *BindingData) Reset()

func (*BindingData) String 

func (x *BindingData) String() string

type BindingDataCollection 

type BindingDataCollection struct {
	Bindings []*BindingData `protobuf:"bytes,1,rep,name=bindings,proto3" json:"bindings,omitempty"`
	// contains filtered or unexported fields
}

A collection of BindingData items.

func (*BindingDataCollection) Descriptor deprecated 

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

Deprecated: Use BindingDataCollection.ProtoReflect.Descriptor instead.

func (*BindingDataCollection) GetBindings 

func (x *BindingDataCollection) GetBindings() []*BindingData

func (*BindingDataCollection) ProtoMessage 

func (*BindingDataCollection) ProtoMessage()

func (*BindingDataCollection) ProtoReflect added in v1.10.7 

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

func (*BindingDataCollection) Reset 

func (x *BindingDataCollection) Reset()

func (*BindingDataCollection) String 

func (x *BindingDataCollection) String() string

type BindingDataMap 

type BindingDataMap struct {
	Bindings map[string]*BindingData `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

A map of BindingData items.

func (*BindingDataMap) Descriptor deprecated 

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

Deprecated: Use BindingDataMap.ProtoReflect.Descriptor instead.

func (*BindingDataMap) GetBindings 

func (x *BindingDataMap) GetBindings() map[string]*BindingData

func (*BindingDataMap) ProtoMessage 

func (*BindingDataMap) ProtoMessage()

func (*BindingDataMap) ProtoReflect added in v1.10.7 

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

func (*BindingDataMap) Reset 

func (x *BindingDataMap) Reset()

func (*BindingDataMap) String 

func (x *BindingDataMap) String() string

type BindingData_Collection 

type BindingData_Collection struct {
	// A collection of binding data. This allows nesting of binding data to any number
	// of levels.
	Collection *BindingDataCollection `protobuf:"bytes,2,opt,name=collection,proto3,oneof"`
}

type BindingData_Map 

type BindingData_Map struct {
	// A map of bindings. The key is always a string.
	Map *BindingDataMap `protobuf:"bytes,4,opt,name=map,proto3,oneof"`
}

type BindingData_Promise 

type BindingData_Promise struct {
	// References an output promised by another node.
	Promise *OutputReference `protobuf:"bytes,3,opt,name=promise,proto3,oneof"`
}

type BindingData_Scalar 

type BindingData_Scalar struct {
	// A simple scalar value.
	Scalar *Scalar `protobuf:"bytes,1,opt,name=scalar,proto3,oneof"`
}

type Blob 

type Blob struct {
	Metadata *BlobMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Uri      string        `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	// contains filtered or unexported fields
}

Refers to an offloaded set of files. It encapsulates the type of the store and a unique uri for where the data is. There are no restrictions on how the uri is formatted since it will depend on how to interact with the store.

func (*Blob) Descriptor deprecated 

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

Deprecated: Use Blob.ProtoReflect.Descriptor instead.

func (*Blob) GetMetadata 

func (x *Blob) GetMetadata() *BlobMetadata

func (*Blob) GetUri 

func (x *Blob) GetUri() string

func (*Blob) ProtoMessage 

func (*Blob) ProtoMessage()

func (*Blob) ProtoReflect added in v1.10.7 

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

func (*Blob) Reset 

func (x *Blob) Reset()

func (*Blob) String 

func (x *Blob) String() string

type BlobMetadata 

type BlobMetadata struct {
	Type *BlobType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*BlobMetadata) Descriptor deprecated 

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

Deprecated: Use BlobMetadata.ProtoReflect.Descriptor instead.

func (*BlobMetadata) GetType 

func (x *BlobMetadata) GetType() *BlobType

func (*BlobMetadata) ProtoMessage 

func (*BlobMetadata) ProtoMessage()

func (*BlobMetadata) ProtoReflect added in v1.10.7 

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

func (*BlobMetadata) Reset 

func (x *BlobMetadata) Reset()

func (*BlobMetadata) String 

func (x *BlobMetadata) String() string

type BlobType 

type BlobType struct {

	// Format can be a free form string understood by SDK/UI etc like
	// csv, parquet etc
	Format         string                      `protobuf:"bytes,1,opt,name=format,proto3" json:"format,omitempty"`
	Dimensionality BlobType_BlobDimensionality `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

Defines type behavior for blob objects

func (*BlobType) Descriptor deprecated 

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

Deprecated: Use BlobType.ProtoReflect.Descriptor instead.

func (*BlobType) GetDimensionality 

func (x *BlobType) GetDimensionality() BlobType_BlobDimensionality

func (*BlobType) GetFormat 

func (x *BlobType) GetFormat() string

func (*BlobType) ProtoMessage 

func (*BlobType) ProtoMessage()

func (*BlobType) ProtoReflect added in v1.10.7 

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

func (*BlobType) Reset 

func (x *BlobType) Reset()

func (*BlobType) String 

func (x *BlobType) String() string

type BlobType_BlobDimensionality 

type BlobType_BlobDimensionality int32
const (
	BlobType_SINGLE    BlobType_BlobDimensionality = 0
	BlobType_MULTIPART BlobType_BlobDimensionality = 1
)

func (BlobType_BlobDimensionality) Descriptor added in v1.10.7 

func (BlobType_BlobDimensionality) Descriptor() protoreflect.EnumDescriptor

func (BlobType_BlobDimensionality) Enum added in v1.10.7 

func (x BlobType_BlobDimensionality) Enum() *BlobType_BlobDimensionality

func (BlobType_BlobDimensionality) EnumDescriptor deprecated 

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

Deprecated: Use BlobType_BlobDimensionality.Descriptor instead.

func (BlobType_BlobDimensionality) Number added in v1.10.7 

func (x BlobType_BlobDimensionality) Number() protoreflect.EnumNumber

func (BlobType_BlobDimensionality) String 

func (x BlobType_BlobDimensionality) String() string

func (BlobType_BlobDimensionality) Type added in v1.10.7 

func (BlobType_BlobDimensionality) Type() protoreflect.EnumType

type BooleanExpression 

type BooleanExpression struct {

	// Types that are assignable to Expr:
	//
	//	*BooleanExpression_Conjunction
	//	*BooleanExpression_Comparison
	Expr isBooleanExpression_Expr `protobuf_oneof:"expr"`
	// contains filtered or unexported fields
}

Defines a boolean expression tree. It can be a simple or a conjunction expression. Multiple expressions can be combined using a conjunction or a disjunction to result in a final boolean result.

func (*BooleanExpression) Descriptor deprecated 

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

Deprecated: Use BooleanExpression.ProtoReflect.Descriptor instead.

func (*BooleanExpression) GetComparison 

func (x *BooleanExpression) GetComparison() *ComparisonExpression

func (*BooleanExpression) GetConjunction 

func (x *BooleanExpression) GetConjunction() *ConjunctionExpression

func (*BooleanExpression) GetExpr 

func (m *BooleanExpression) GetExpr() isBooleanExpression_Expr

func (*BooleanExpression) ProtoMessage 

func (*BooleanExpression) ProtoMessage()

func (*BooleanExpression) ProtoReflect added in v1.10.7 

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

func (*BooleanExpression) Reset 

func (x *BooleanExpression) Reset()

func (*BooleanExpression) String 

func (x *BooleanExpression) String() string

type BooleanExpression_Comparison 

type BooleanExpression_Comparison struct {
	Comparison *ComparisonExpression `protobuf:"bytes,2,opt,name=comparison,proto3,oneof"`
}

type BooleanExpression_Conjunction 

type BooleanExpression_Conjunction struct {
	Conjunction *ConjunctionExpression `protobuf:"bytes,1,opt,name=conjunction,proto3,oneof"`
}

type BranchNode 

type BranchNode struct {

	// +required
	IfElse *IfElseBlock `protobuf:"bytes,1,opt,name=if_else,json=ifElse,proto3" json:"if_else,omitempty"`
	// contains filtered or unexported fields
}

BranchNode is a special node that alter the flow of the workflow graph. It allows the control flow to branch at runtime based on a series of conditions that get evaluated on various parameters (e.g. inputs, primitives).

func (*BranchNode) Descriptor deprecated 

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

Deprecated: Use BranchNode.ProtoReflect.Descriptor instead.

func (*BranchNode) GetIfElse 

func (x *BranchNode) GetIfElse() *IfElseBlock

func (*BranchNode) ProtoMessage 

func (*BranchNode) ProtoMessage()

func (*BranchNode) ProtoReflect added in v1.10.7 

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

func (*BranchNode) Reset 

func (x *BranchNode) Reset()

func (*BranchNode) String 

func (x *BranchNode) String() string

type CatalogArtifactTag 

type CatalogArtifactTag struct {

	// Artifact ID is generated name
	ArtifactId string `protobuf:"bytes,1,opt,name=artifact_id,json=artifactId,proto3" json:"artifact_id,omitempty"`
	// Flyte computes the tag automatically, as the hash of the values
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CatalogArtifactTag) Descriptor deprecated 

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

Deprecated: Use CatalogArtifactTag.ProtoReflect.Descriptor instead.

func (*CatalogArtifactTag) GetArtifactId 

func (x *CatalogArtifactTag) GetArtifactId() string

func (*CatalogArtifactTag) GetName 

func (x *CatalogArtifactTag) GetName() string

func (*CatalogArtifactTag) ProtoMessage 

func (*CatalogArtifactTag) ProtoMessage()

func (*CatalogArtifactTag) ProtoReflect added in v1.10.7 

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

func (*CatalogArtifactTag) Reset 

func (x *CatalogArtifactTag) Reset()

func (*CatalogArtifactTag) String 

func (x *CatalogArtifactTag) String() string

type CatalogCacheStatus 

type CatalogCacheStatus int32

Indicates the status of CatalogCaching. The reason why this is not embedded in TaskNodeMetadata is, that we may use for other types of nodes as well in the future 

const (
	// Used to indicate that caching was disabled
	CatalogCacheStatus_CACHE_DISABLED CatalogCacheStatus = 0
	// Used to indicate that the cache lookup resulted in no matches
	CatalogCacheStatus_CACHE_MISS CatalogCacheStatus = 1
	// used to indicate that the associated artifact was a result of a previous execution
	CatalogCacheStatus_CACHE_HIT CatalogCacheStatus = 2
	// used to indicate that the resultant artifact was added to the cache
	CatalogCacheStatus_CACHE_POPULATED CatalogCacheStatus = 3
	// Used to indicate that cache lookup failed because of an error
	CatalogCacheStatus_CACHE_LOOKUP_FAILURE CatalogCacheStatus = 4
	// Used to indicate that cache lookup failed because of an error
	CatalogCacheStatus_CACHE_PUT_FAILURE CatalogCacheStatus = 5
	// Used to indicate the cache lookup was skipped
	CatalogCacheStatus_CACHE_SKIPPED CatalogCacheStatus = 6
	// Used to indicate that the cache was evicted
	CatalogCacheStatus_CACHE_EVICTED CatalogCacheStatus = 7
)

func (CatalogCacheStatus) Descriptor added in v1.10.7 

func (CatalogCacheStatus) Descriptor() protoreflect.EnumDescriptor

func (CatalogCacheStatus) Enum added in v1.10.7 

func (x CatalogCacheStatus) Enum() *CatalogCacheStatus

func (CatalogCacheStatus) EnumDescriptor deprecated 

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

Deprecated: Use CatalogCacheStatus.Descriptor instead.

func (CatalogCacheStatus) Number added in v1.10.7 

func (x CatalogCacheStatus) Number() protoreflect.EnumNumber

func (CatalogCacheStatus) String 

func (x CatalogCacheStatus) String() string

func (CatalogCacheStatus) Type added in v1.10.7 

func (CatalogCacheStatus) Type() protoreflect.EnumType

type CatalogMetadata 

type CatalogMetadata struct {

	// Dataset ID in the catalog
	DatasetId *Identifier `protobuf:"bytes,1,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	// Artifact tag in the catalog
	ArtifactTag *CatalogArtifactTag `protobuf:"bytes,2,opt,name=artifact_tag,json=artifactTag,proto3" json:"artifact_tag,omitempty"`
	// Optional: Source Execution identifier, if this dataset was generated by another execution in Flyte. This is a one-of field and will depend on the caching context
	//
	// Types that are assignable to SourceExecution:
	//
	//	*CatalogMetadata_SourceTaskExecution
	SourceExecution isCatalogMetadata_SourceExecution `protobuf_oneof:"source_execution"`
	// contains filtered or unexported fields
}

Catalog artifact information with specific metadata

func (*CatalogMetadata) Descriptor deprecated 

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

Deprecated: Use CatalogMetadata.ProtoReflect.Descriptor instead.

func (*CatalogMetadata) GetArtifactTag 

func (x *CatalogMetadata) GetArtifactTag() *CatalogArtifactTag

func (*CatalogMetadata) GetDatasetId 

func (x *CatalogMetadata) GetDatasetId() *Identifier

func (*CatalogMetadata) GetSourceExecution 

func (m *CatalogMetadata) GetSourceExecution() isCatalogMetadata_SourceExecution

func (*CatalogMetadata) GetSourceTaskExecution 

func (x *CatalogMetadata) GetSourceTaskExecution() *TaskExecutionIdentifier

func (*CatalogMetadata) ProtoMessage 

func (*CatalogMetadata) ProtoMessage()

func (*CatalogMetadata) ProtoReflect added in v1.10.7 

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

func (*CatalogMetadata) Reset 

func (x *CatalogMetadata) Reset()

func (*CatalogMetadata) String 

func (x *CatalogMetadata) String() string

type CatalogMetadata_SourceTaskExecution 

type CatalogMetadata_SourceTaskExecution struct {
	// Today we only support TaskExecutionIdentifier as a source, as catalog caching only works for task executions
	SourceTaskExecution *TaskExecutionIdentifier `protobuf:"bytes,3,opt,name=source_task_execution,json=sourceTaskExecution,proto3,oneof"`
}

type CatalogReservation 

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

func (*CatalogReservation) Descriptor deprecated 

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

Deprecated: Use CatalogReservation.ProtoReflect.Descriptor instead.

func (*CatalogReservation) ProtoMessage 

func (*CatalogReservation) ProtoMessage()

func (*CatalogReservation) ProtoReflect added in v1.10.7 

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

func (*CatalogReservation) Reset 

func (x *CatalogReservation) Reset()

func (*CatalogReservation) String 

func (x *CatalogReservation) String() string

type CatalogReservation_Status 

type CatalogReservation_Status int32

Indicates the status of a catalog reservation operation. 

const (
	// Used to indicate that reservations are disabled
	CatalogReservation_RESERVATION_DISABLED CatalogReservation_Status = 0
	// Used to indicate that a reservation was successfully acquired or extended
	CatalogReservation_RESERVATION_ACQUIRED CatalogReservation_Status = 1
	// Used to indicate that an active reservation currently exists
	CatalogReservation_RESERVATION_EXISTS CatalogReservation_Status = 2
	// Used to indicate that the reservation has been successfully released
	CatalogReservation_RESERVATION_RELEASED CatalogReservation_Status = 3
	// Used to indicate that a reservation operation resulted in failure
	CatalogReservation_RESERVATION_FAILURE CatalogReservation_Status = 4
)

func (CatalogReservation_Status) Descriptor added in v1.10.7 

func (CatalogReservation_Status) Descriptor() protoreflect.EnumDescriptor

func (CatalogReservation_Status) Enum added in v1.10.7 

func (x CatalogReservation_Status) Enum() *CatalogReservation_Status

func (CatalogReservation_Status) EnumDescriptor deprecated 

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

Deprecated: Use CatalogReservation_Status.Descriptor instead.

func (CatalogReservation_Status) Number added in v1.10.7 

func (x CatalogReservation_Status) Number() protoreflect.EnumNumber

func (CatalogReservation_Status) String 

func (x CatalogReservation_Status) String() string

func (CatalogReservation_Status) Type added in v1.10.7 

func (CatalogReservation_Status) Type() protoreflect.EnumType

type ComparisonExpression 

type ComparisonExpression struct {
	Operator   ComparisonExpression_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=flyteidl.core.ComparisonExpression_Operator" json:"operator,omitempty"`
	LeftValue  *Operand                      `protobuf:"bytes,2,opt,name=left_value,json=leftValue,proto3" json:"left_value,omitempty"`
	RightValue *Operand                      `protobuf:"bytes,3,opt,name=right_value,json=rightValue,proto3" json:"right_value,omitempty"`
	// contains filtered or unexported fields
}

Defines a 2-level tree where the root is a comparison operator and Operands are primitives or known variables. Each expression results in a boolean result.

func (*ComparisonExpression) Descriptor deprecated 

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

Deprecated: Use ComparisonExpression.ProtoReflect.Descriptor instead.

func (*ComparisonExpression) GetLeftValue 

func (x *ComparisonExpression) GetLeftValue() *Operand

func (*ComparisonExpression) GetOperator 

func (x *ComparisonExpression) GetOperator() ComparisonExpression_Operator

func (*ComparisonExpression) GetRightValue 

func (x *ComparisonExpression) GetRightValue() *Operand

func (*ComparisonExpression) ProtoMessage 

func (*ComparisonExpression) ProtoMessage()

func (*ComparisonExpression) ProtoReflect added in v1.10.7 

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

func (*ComparisonExpression) Reset 

func (x *ComparisonExpression) Reset()

func (*ComparisonExpression) String 

func (x *ComparisonExpression) String() string

type ComparisonExpression_Operator 

type ComparisonExpression_Operator int32

Binary Operator for each expression 

const (
	ComparisonExpression_EQ  ComparisonExpression_Operator = 0
	ComparisonExpression_NEQ ComparisonExpression_Operator = 1
	// Greater Than
	ComparisonExpression_GT  ComparisonExpression_Operator = 2
	ComparisonExpression_GTE ComparisonExpression_Operator = 3
	// Less Than
	ComparisonExpression_LT  ComparisonExpression_Operator = 4
	ComparisonExpression_LTE ComparisonExpression_Operator = 5
)

func (ComparisonExpression_Operator) Descriptor added in v1.10.7 

func (ComparisonExpression_Operator) Descriptor() protoreflect.EnumDescriptor

func (ComparisonExpression_Operator) Enum added in v1.10.7 

func (x ComparisonExpression_Operator) Enum() *ComparisonExpression_Operator

func (ComparisonExpression_Operator) EnumDescriptor deprecated 

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

Deprecated: Use ComparisonExpression_Operator.Descriptor instead.

func (ComparisonExpression_Operator) Number added in v1.10.7 

func (x ComparisonExpression_Operator) Number() protoreflect.EnumNumber

func (ComparisonExpression_Operator) String 

func (x ComparisonExpression_Operator) String() string

func (ComparisonExpression_Operator) Type added in v1.10.7 

func (ComparisonExpression_Operator) Type() protoreflect.EnumType

type CompiledLaunchPlan added in v1.10.7 

type CompiledLaunchPlan struct {

	// Completely contained LaunchPlan Template
	Template *LaunchPlanTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// contains filtered or unexported fields
}

Output of the compilation step. This object represents one LaunchPlan. We store more metadata at this layer

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

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

Deprecated: Use CompiledLaunchPlan.ProtoReflect.Descriptor instead.

func (*CompiledLaunchPlan) GetTemplate added in v1.10.7 

func (x *CompiledLaunchPlan) GetTemplate() *LaunchPlanTemplate

func (*CompiledLaunchPlan) ProtoMessage added in v1.10.7 

func (*CompiledLaunchPlan) ProtoMessage()

func (*CompiledLaunchPlan) ProtoReflect added in v1.10.7 

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

func (*CompiledLaunchPlan) Reset added in v1.10.7 

func (x *CompiledLaunchPlan) Reset()

func (*CompiledLaunchPlan) String added in v1.10.7 

func (x *CompiledLaunchPlan) String() string

type CompiledTask 

type CompiledTask struct {

	// Completely contained TaskTemplate
	Template *TaskTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// contains filtered or unexported fields
}

Output of the Compilation step. This object represent one Task. We store more metadata at this layer

func (*CompiledTask) Descriptor deprecated 

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

Deprecated: Use CompiledTask.ProtoReflect.Descriptor instead.

func (*CompiledTask) GetTemplate 

func (x *CompiledTask) GetTemplate() *TaskTemplate

func (*CompiledTask) ProtoMessage 

func (*CompiledTask) ProtoMessage()

func (*CompiledTask) ProtoReflect added in v1.10.7 

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

func (*CompiledTask) Reset 

func (x *CompiledTask) Reset()

func (*CompiledTask) String 

func (x *CompiledTask) String() string

type CompiledWorkflow 

type CompiledWorkflow struct {

	// Completely contained Workflow Template
	Template *WorkflowTemplate `protobuf:"bytes,1,opt,name=template,proto3" json:"template,omitempty"`
	// For internal use only! This field is used by the system and must not be filled in. Any values set will be ignored.
	Connections *ConnectionSet `protobuf:"bytes,2,opt,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

Output of the compilation Step. This object represents one workflow. We store more metadata at this layer

func (*CompiledWorkflow) Descriptor deprecated 

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

Deprecated: Use CompiledWorkflow.ProtoReflect.Descriptor instead.

func (*CompiledWorkflow) GetConnections 

func (x *CompiledWorkflow) GetConnections() *ConnectionSet

func (*CompiledWorkflow) GetTemplate 

func (x *CompiledWorkflow) GetTemplate() *WorkflowTemplate

func (*CompiledWorkflow) ProtoMessage 

func (*CompiledWorkflow) ProtoMessage()

func (*CompiledWorkflow) ProtoReflect added in v1.10.7 

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

func (*CompiledWorkflow) Reset 

func (x *CompiledWorkflow) Reset()

func (*CompiledWorkflow) String 

func (x *CompiledWorkflow) String() string

type CompiledWorkflowClosure 

type CompiledWorkflowClosure struct {

	// +required
	Primary *CompiledWorkflow `protobuf:"bytes,1,opt,name=primary,proto3" json:"primary,omitempty"`
	// Guaranteed that there will only exist one and only one workflow with a given id, i.e., every sub workflow has a
	// unique identifier. Also every enclosed subworkflow is used either by a primary workflow or by a subworkflow
	// as an inlined workflow
	// +optional
	SubWorkflows []*CompiledWorkflow `protobuf:"bytes,2,rep,name=sub_workflows,json=subWorkflows,proto3" json:"sub_workflows,omitempty"`
	// Guaranteed that there will only exist one and only one task with a given id, i.e., every task has a unique id
	// +required (at least 1)
	Tasks []*CompiledTask `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// A collection of launch plans that are compiled. Guaranteed that there will only exist one and only one launch plan
	// with a given id, i.e., every launch plan has a unique id.
	LaunchPlans []*CompiledLaunchPlan `protobuf:"bytes,4,rep,name=launch_plans,json=launchPlans,proto3" json:"launch_plans,omitempty"`
	// contains filtered or unexported fields
}

A Compiled Workflow Closure contains all the information required to start a new execution, or to visualize a workflow and its details. The CompiledWorkflowClosure should always contain a primary workflow, that is the main workflow that will being the execution. All subworkflows are denormalized. WorkflowNodes refer to the workflow identifiers of compiled subworkflows.

func (*CompiledWorkflowClosure) Descriptor deprecated 

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

Deprecated: Use CompiledWorkflowClosure.ProtoReflect.Descriptor instead.

func (*CompiledWorkflowClosure) GetLaunchPlans added in v1.10.7 

func (x *CompiledWorkflowClosure) GetLaunchPlans() []*CompiledLaunchPlan

func (*CompiledWorkflowClosure) GetPrimary 

func (x *CompiledWorkflowClosure) GetPrimary() *CompiledWorkflow

func (*CompiledWorkflowClosure) GetSubWorkflows 

func (x *CompiledWorkflowClosure) GetSubWorkflows() []*CompiledWorkflow

func (*CompiledWorkflowClosure) GetTasks 

func (x *CompiledWorkflowClosure) GetTasks() []*CompiledTask

func (*CompiledWorkflowClosure) ProtoMessage 

func (*CompiledWorkflowClosure) ProtoMessage()

func (*CompiledWorkflowClosure) ProtoReflect added in v1.10.7 

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

func (*CompiledWorkflowClosure) Reset 

func (x *CompiledWorkflowClosure) Reset()

func (*CompiledWorkflowClosure) String 

func (x *CompiledWorkflowClosure) String() string

type ConjunctionExpression 

type ConjunctionExpression struct {
	Operator        ConjunctionExpression_LogicalOperator `` /* 127-byte string literal not displayed */
	LeftExpression  *BooleanExpression                    `protobuf:"bytes,2,opt,name=left_expression,json=leftExpression,proto3" json:"left_expression,omitempty"`
	RightExpression *BooleanExpression                    `protobuf:"bytes,3,opt,name=right_expression,json=rightExpression,proto3" json:"right_expression,omitempty"`
	// contains filtered or unexported fields
}

Defines a conjunction expression of two boolean expressions.

func (*ConjunctionExpression) Descriptor deprecated 

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

Deprecated: Use ConjunctionExpression.ProtoReflect.Descriptor instead.

func (*ConjunctionExpression) GetLeftExpression 

func (x *ConjunctionExpression) GetLeftExpression() *BooleanExpression

func (*ConjunctionExpression) GetOperator 

func (x *ConjunctionExpression) GetOperator() ConjunctionExpression_LogicalOperator

func (*ConjunctionExpression) GetRightExpression 

func (x *ConjunctionExpression) GetRightExpression() *BooleanExpression

func (*ConjunctionExpression) ProtoMessage 

func (*ConjunctionExpression) ProtoMessage()

func (*ConjunctionExpression) ProtoReflect added in v1.10.7 

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

func (*ConjunctionExpression) Reset 

func (x *ConjunctionExpression) Reset()

func (*ConjunctionExpression) String 

func (x *ConjunctionExpression) String() string

type ConjunctionExpression_LogicalOperator 

type ConjunctionExpression_LogicalOperator int32

Nested conditions. They can be conjoined using AND / OR Order of evaluation is not important as the operators are Commutative 

const (
	// Conjunction
	ConjunctionExpression_AND ConjunctionExpression_LogicalOperator = 0
	ConjunctionExpression_OR  ConjunctionExpression_LogicalOperator = 1
)

func (ConjunctionExpression_LogicalOperator) Descriptor added in v1.10.7 

func (ConjunctionExpression_LogicalOperator) Descriptor() protoreflect.EnumDescriptor

func (ConjunctionExpression_LogicalOperator) Enum added in v1.10.7 

func (x ConjunctionExpression_LogicalOperator) Enum() *ConjunctionExpression_LogicalOperator

func (ConjunctionExpression_LogicalOperator) EnumDescriptor deprecated 

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

Deprecated: Use ConjunctionExpression_LogicalOperator.Descriptor instead.

func (ConjunctionExpression_LogicalOperator) Number added in v1.10.7 

func (x ConjunctionExpression_LogicalOperator) Number() protoreflect.EnumNumber

func (ConjunctionExpression_LogicalOperator) String 

func (x ConjunctionExpression_LogicalOperator) String() string

func (ConjunctionExpression_LogicalOperator) Type added in v1.10.7 

func (ConjunctionExpression_LogicalOperator) Type() protoreflect.EnumType

type ConnectionSet 

type ConnectionSet struct {

	// A list of all the node ids that are downstream from a given node id
	Downstream map[string]*ConnectionSet_IdList `` /* 161-byte string literal not displayed */
	// A list of all the node ids, that are upstream of this node id
	Upstream map[string]*ConnectionSet_IdList `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Adjacency list for the workflow. This is created as part of the compilation process. Every process after the compilation step uses this created ConnectionSet

func (*ConnectionSet) Descriptor deprecated 

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

Deprecated: Use ConnectionSet.ProtoReflect.Descriptor instead.

func (*ConnectionSet) GetDownstream 

func (x *ConnectionSet) GetDownstream() map[string]*ConnectionSet_IdList

func (*ConnectionSet) GetUpstream 

func (x *ConnectionSet) GetUpstream() map[string]*ConnectionSet_IdList

func (*ConnectionSet) ProtoMessage 

func (*ConnectionSet) ProtoMessage()

func (*ConnectionSet) ProtoReflect added in v1.10.7 

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

func (*ConnectionSet) Reset 

func (x *ConnectionSet) Reset()

func (*ConnectionSet) String 

func (x *ConnectionSet) String() string

type ConnectionSet_IdList 

type ConnectionSet_IdList struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionSet_IdList) Descriptor deprecated 

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

Deprecated: Use ConnectionSet_IdList.ProtoReflect.Descriptor instead.

func (*ConnectionSet_IdList) GetIds 

func (x *ConnectionSet_IdList) GetIds() []string

func (*ConnectionSet_IdList) ProtoMessage 

func (*ConnectionSet_IdList) ProtoMessage()

func (*ConnectionSet_IdList) ProtoReflect added in v1.10.7 

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

func (*ConnectionSet_IdList) Reset 

func (x *ConnectionSet_IdList) Reset()

func (*ConnectionSet_IdList) String 

func (x *ConnectionSet_IdList) String() string

type Container 

type Container struct {

	// Container image url. Eg: docker/redis:latest
	Image string `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	// Command to be executed, if not provided, the default entrypoint in the container image will be used.
	Command []string `protobuf:"bytes,2,rep,name=command,proto3" json:"command,omitempty"`
	// These will default to Flyte given paths. If provided, the system will not append known paths. If the task still
	// needs flyte's inputs and outputs path, add $(FLYTE_INPUT_FILE), $(FLYTE_OUTPUT_FILE) wherever makes sense and the
	// system will populate these before executing the container.
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// Container resources requirement as specified by the container engine.
	Resources *Resources `protobuf:"bytes,4,opt,name=resources,proto3" json:"resources,omitempty"`
	// Environment variables will be set as the container is starting up.
	Env []*KeyValuePair `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	// Allows extra configs to be available for the container.
	// TODO: elaborate on how configs will become available.
	// Deprecated, please use TaskTemplate.config instead.
	//
	// Deprecated: Marked as deprecated in flyteidl/core/tasks.proto.
	Config []*KeyValuePair `protobuf:"bytes,6,rep,name=config,proto3" json:"config,omitempty"`
	// Ports to open in the container. This feature is not supported by all execution engines. (e.g. supported on K8s but
	// not supported on AWS Batch)
	// Only K8s
	Ports []*ContainerPort `protobuf:"bytes,7,rep,name=ports,proto3" json:"ports,omitempty"`
	// BETA: Optional configuration for DataLoading. If not specified, then default values are used.
	// This makes it possible to to run a completely portable container, that uses inputs and outputs
	// only from the local file-system and without having any reference to flyteidl. This is supported only on K8s at the moment.
	// If data loading is enabled, then data will be mounted in accompanying directories specified in the DataLoadingConfig. If the directories
	// are not specified, inputs will be mounted onto and outputs will be uploaded from a pre-determined file-system path. Refer to the documentation
	// to understand the default paths.
	// Only K8s
	DataConfig   *DataLoadingConfig     `protobuf:"bytes,9,opt,name=data_config,json=dataConfig,proto3" json:"data_config,omitempty"`
	Architecture Container_Architecture `protobuf:"varint,10,opt,name=architecture,proto3,enum=flyteidl.core.Container_Architecture" json:"architecture,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated 

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetArchitecture 

func (x *Container) GetArchitecture() Container_Architecture

func (*Container) GetArgs 

func (x *Container) GetArgs() []string

func (*Container) GetCommand 

func (x *Container) GetCommand() []string

func (*Container) GetConfig deprecated 

func (x *Container) GetConfig() []*KeyValuePair

Deprecated: Marked as deprecated in flyteidl/core/tasks.proto.

func (*Container) GetDataConfig 

func (x *Container) GetDataConfig() *DataLoadingConfig

func (*Container) GetEnv 

func (x *Container) GetEnv() []*KeyValuePair

func (*Container) GetImage 

func (x *Container) GetImage() string

func (*Container) GetPorts 

func (x *Container) GetPorts() []*ContainerPort

func (*Container) GetResources 

func (x *Container) GetResources() *Resources

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect added in v1.10.7 

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

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) String 

func (x *Container) String() string

type ContainerError 

type ContainerError struct {

	// A simplified code for errors, so that we can provide a glossary of all possible errors.
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// A detailed error message.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// An abstract error kind for this error. Defaults to Non_Recoverable if not specified.
	Kind ContainerError_Kind `protobuf:"varint,3,opt,name=kind,proto3,enum=flyteidl.core.ContainerError_Kind" json:"kind,omitempty"`
	// Defines the origin of the error (system, user, unknown).
	Origin ExecutionError_ErrorKind `protobuf:"varint,4,opt,name=origin,proto3,enum=flyteidl.core.ExecutionError_ErrorKind" json:"origin,omitempty"`
	// contains filtered or unexported fields
}

Error message to propagate detailed errors from container executions to the execution engine.

func (*ContainerError) Descriptor deprecated 

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

Deprecated: Use ContainerError.ProtoReflect.Descriptor instead.

func (*ContainerError) GetCode 

func (x *ContainerError) GetCode() string

func (*ContainerError) GetKind 

func (x *ContainerError) GetKind() ContainerError_Kind

func (*ContainerError) GetMessage 

func (x *ContainerError) GetMessage() string

func (*ContainerError) GetOrigin 

func (x *ContainerError) GetOrigin() ExecutionError_ErrorKind

func (*ContainerError) ProtoMessage 

func (*ContainerError) ProtoMessage()

func (*ContainerError) ProtoReflect added in v1.10.7 

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

func (*ContainerError) Reset 

func (x *ContainerError) Reset()

func (*ContainerError) String 

func (x *ContainerError) String() string

type ContainerError_Kind 

type ContainerError_Kind int32

Defines a generic error type that dictates the behavior of the retry strategy. 

const (
	ContainerError_NON_RECOVERABLE ContainerError_Kind = 0
	ContainerError_RECOVERABLE     ContainerError_Kind = 1
)

func (ContainerError_Kind) Descriptor added in v1.10.7 

func (ContainerError_Kind) Descriptor() protoreflect.EnumDescriptor

func (ContainerError_Kind) Enum added in v1.10.7 

func (x ContainerError_Kind) Enum() *ContainerError_Kind

func (ContainerError_Kind) EnumDescriptor deprecated 

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

Deprecated: Use ContainerError_Kind.Descriptor instead.

func (ContainerError_Kind) Number added in v1.10.7 

func (x ContainerError_Kind) Number() protoreflect.EnumNumber

func (ContainerError_Kind) String 

func (x ContainerError_Kind) String() string

func (ContainerError_Kind) Type added in v1.10.7 

func (ContainerError_Kind) Type() protoreflect.EnumType

type ContainerPort 

type ContainerPort struct {

	// Number of port to expose on the pod's IP address.
	// This must be a valid port number, 0 < x < 65536.
	ContainerPort uint32 `protobuf:"varint,1,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	// contains filtered or unexported fields
}

Defines port properties for a container.

func (*ContainerPort) Descriptor deprecated 

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

Deprecated: Use ContainerPort.ProtoReflect.Descriptor instead.

func (*ContainerPort) GetContainerPort 

func (x *ContainerPort) GetContainerPort() uint32

func (*ContainerPort) ProtoMessage 

func (*ContainerPort) ProtoMessage()

func (*ContainerPort) ProtoReflect added in v1.10.7 

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

func (*ContainerPort) Reset 

func (x *ContainerPort) Reset()

func (*ContainerPort) String 

func (x *ContainerPort) String() string

type Container_Architecture 

type Container_Architecture int32

Architecture-type the container image supports. 

const (
	Container_UNKNOWN Container_Architecture = 0
	Container_AMD64   Container_Architecture = 1
	Container_ARM64   Container_Architecture = 2
	Container_ARM_V6  Container_Architecture = 3
	Container_ARM_V7  Container_Architecture = 4
)

func (Container_Architecture) Descriptor added in v1.10.7 

func (Container_Architecture) Descriptor() protoreflect.EnumDescriptor

func (Container_Architecture) Enum added in v1.10.7 

func (x Container_Architecture) Enum() *Container_Architecture

func (Container_Architecture) EnumDescriptor deprecated 

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

Deprecated: Use Container_Architecture.Descriptor instead.

func (Container_Architecture) Number added in v1.10.7 

func (x Container_Architecture) Number() protoreflect.EnumNumber

func (Container_Architecture) String 

func (x Container_Architecture) String() string

func (Container_Architecture) Type added in v1.10.7 

func (Container_Architecture) Type() protoreflect.EnumType

type DataLoadingConfig 

type DataLoadingConfig struct {

	// Flag enables DataLoading Config. If this is not set, data loading will not be used!
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// File system path (start at root). This folder will contain all the inputs exploded to a separate file.
	// Example, if the input interface needs (x: int, y: blob, z: multipart_blob) and the input path is '/var/flyte/inputs', then the file system will look like
	// /var/flyte/inputs/inputs.<metadata format dependent -> .pb .json .yaml> -> Format as defined previously. The Blob and Multipart blob will reference local filesystem instead of remote locations
	// /var/flyte/inputs/x -> X is a file that contains the value of x (integer) in string format
	// /var/flyte/inputs/y -> Y is a file in Binary format
	// /var/flyte/inputs/z/... -> Note Z itself is a directory
	// More information about the protocol - refer to docs #TODO reference docs here
	InputPath string `protobuf:"bytes,2,opt,name=input_path,json=inputPath,proto3" json:"input_path,omitempty"`
	// File system path (start at root). This folder should contain all the outputs for the task as individual files and/or an error text file
	OutputPath string `protobuf:"bytes,3,opt,name=output_path,json=outputPath,proto3" json:"output_path,omitempty"`
	// In the inputs folder, there will be an additional summary/metadata file that contains references to all files or inlined primitive values.
	// This format decides the actual encoding for the data. Refer to the encoding to understand the specifics of the contents and the encoding
	Format     DataLoadingConfig_LiteralMapFormat `protobuf:"varint,4,opt,name=format,proto3,enum=flyteidl.core.DataLoadingConfig_LiteralMapFormat" json:"format,omitempty"`
	IoStrategy *IOStrategy                        `protobuf:"bytes,5,opt,name=io_strategy,json=ioStrategy,proto3" json:"io_strategy,omitempty"`
	// contains filtered or unexported fields
}

This configuration allows executing raw containers in Flyte using the Flyte CoPilot system. Flyte CoPilot, eliminates the needs of flytekit or sdk inside the container. Any inputs required by the users container are side-loaded in the input_path Any outputs generated by the user container - within output_path are automatically uploaded.

func (*DataLoadingConfig) Descriptor deprecated 

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

Deprecated: Use DataLoadingConfig.ProtoReflect.Descriptor instead.

func (*DataLoadingConfig) GetEnabled 

func (x *DataLoadingConfig) GetEnabled() bool

func (*DataLoadingConfig) GetFormat 

func (x *DataLoadingConfig) GetFormat() DataLoadingConfig_LiteralMapFormat

func (*DataLoadingConfig) GetInputPath 

func (x *DataLoadingConfig) GetInputPath() string

func (*DataLoadingConfig) GetIoStrategy 

func (x *DataLoadingConfig) GetIoStrategy() *IOStrategy

func (*DataLoadingConfig) GetOutputPath 

func (x *DataLoadingConfig) GetOutputPath() string

func (*DataLoadingConfig) ProtoMessage 

func (*DataLoadingConfig) ProtoMessage()

func (*DataLoadingConfig) ProtoReflect added in v1.10.7 

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

func (*DataLoadingConfig) Reset 

func (x *DataLoadingConfig) Reset()

func (*DataLoadingConfig) String 

func (x *DataLoadingConfig) String() string

type DataLoadingConfig_LiteralMapFormat 

type DataLoadingConfig_LiteralMapFormat int32

LiteralMapFormat decides the encoding format in which the input metadata should be made available to the containers. If the user has access to the protocol buffer definitions, it is recommended to use the PROTO format. JSON and YAML do not need any protobuf definitions to read it All remote references in core.LiteralMap are replaced with local filesystem references (the data is downloaded to local filesystem) 

const (
	// JSON / YAML for the metadata (which contains inlined primitive values). The representation is inline with the standard json specification as specified - https://www.json.org/json-en.html
	DataLoadingConfig_JSON DataLoadingConfig_LiteralMapFormat = 0
	DataLoadingConfig_YAML DataLoadingConfig_LiteralMapFormat = 1
	// Proto is a serialized binary of `core.LiteralMap` defined in flyteidl/core
	DataLoadingConfig_PROTO DataLoadingConfig_LiteralMapFormat = 2
)

func (DataLoadingConfig_LiteralMapFormat) Descriptor added in v1.10.7 

func (DataLoadingConfig_LiteralMapFormat) Descriptor() protoreflect.EnumDescriptor

func (DataLoadingConfig_LiteralMapFormat) Enum added in v1.10.7 

func (x DataLoadingConfig_LiteralMapFormat) Enum() *DataLoadingConfig_LiteralMapFormat

func (DataLoadingConfig_LiteralMapFormat) EnumDescriptor deprecated 

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

Deprecated: Use DataLoadingConfig_LiteralMapFormat.Descriptor instead.

func (DataLoadingConfig_LiteralMapFormat) Number added in v1.10.7 

func (x DataLoadingConfig_LiteralMapFormat) Number() protoreflect.EnumNumber

func (DataLoadingConfig_LiteralMapFormat) String 

func (x DataLoadingConfig_LiteralMapFormat) String() string

func (DataLoadingConfig_LiteralMapFormat) Type added in v1.10.7 

func (DataLoadingConfig_LiteralMapFormat) Type() protoreflect.EnumType

type DynamicJobSpec 

type DynamicJobSpec struct {

	// A collection of nodes to execute.
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// An absolute number of successful completions of nodes required to mark this job as succeeded. As soon as this
	// criteria is met, the dynamic job will be marked as successful and outputs will be computed. If this number
	// becomes impossible to reach (e.g. number of currently running tasks + number of already succeeded tasks <
	// min_successes) the task will be aborted immediately and marked as failed. The default value of this field, if not
	// specified, is the count of nodes repeated field.
	MinSuccesses int64 `protobuf:"varint,2,opt,name=min_successes,json=minSuccesses,proto3" json:"min_successes,omitempty"`
	// Describes how to bind the final output of the dynamic job from the outputs of executed nodes. The referenced ids
	// in bindings should have the generated id for the subtask.
	Outputs []*Binding `protobuf:"bytes,3,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// [Optional] A complete list of task specs referenced in nodes.
	Tasks []*TaskTemplate `protobuf:"bytes,4,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// [Optional] A complete list of task specs referenced in nodes.
	Subworkflows []*WorkflowTemplate `protobuf:"bytes,5,rep,name=subworkflows,proto3" json:"subworkflows,omitempty"`
	// contains filtered or unexported fields
}

Describes a set of tasks to execute and how the final outputs are produced.

func (*DynamicJobSpec) Descriptor deprecated 

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

Deprecated: Use DynamicJobSpec.ProtoReflect.Descriptor instead.

func (*DynamicJobSpec) GetMinSuccesses 

func (x *DynamicJobSpec) GetMinSuccesses() int64

func (*DynamicJobSpec) GetNodes 

func (x *DynamicJobSpec) GetNodes() []*Node

func (*DynamicJobSpec) GetOutputs 

func (x *DynamicJobSpec) GetOutputs() []*Binding

func (*DynamicJobSpec) GetSubworkflows 

func (x *DynamicJobSpec) GetSubworkflows() []*WorkflowTemplate

func (*DynamicJobSpec) GetTasks 

func (x *DynamicJobSpec) GetTasks() []*TaskTemplate

func (*DynamicJobSpec) ProtoMessage 

func (*DynamicJobSpec) ProtoMessage()

func (*DynamicJobSpec) ProtoReflect added in v1.10.7 

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

func (*DynamicJobSpec) Reset 

func (x *DynamicJobSpec) Reset()

func (*DynamicJobSpec) String 

func (x *DynamicJobSpec) String() string

type EnumType 

type EnumType struct {

	// Predefined set of enum values.
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Enables declaring enum types, with predefined string values For len(values) > 0, the first value in the ordered list is regarded as the default value. If you wish To provide no defaults, make the first value as undefined.

func (*EnumType) Descriptor deprecated 

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

Deprecated: Use EnumType.ProtoReflect.Descriptor instead.

func (*EnumType) GetValues 

func (x *EnumType) GetValues() []string

func (*EnumType) ProtoMessage 

func (*EnumType) ProtoMessage()

func (*EnumType) ProtoReflect added in v1.10.7 

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

func (*EnumType) Reset 

func (x *EnumType) Reset()

func (*EnumType) String 

func (x *EnumType) String() string

type Error 

type Error struct {

	// The node id that threw the error.
	FailedNodeId string `protobuf:"bytes,1,opt,name=failed_node_id,json=failedNodeId,proto3" json:"failed_node_id,omitempty"`
	// Error message thrown.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Represents an error thrown from a node.

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetFailedNodeId 

func (x *Error) GetFailedNodeId() string

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v1.10.7 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type ErrorDocument 

type ErrorDocument struct {

	// The error raised during execution.
	Error *ContainerError `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Defines the errors.pb file format the container can produce to communicate failure reasons to the execution engine.

func (*ErrorDocument) Descriptor deprecated 

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

Deprecated: Use ErrorDocument.ProtoReflect.Descriptor instead.

func (*ErrorDocument) GetError 

func (x *ErrorDocument) GetError() *ContainerError

func (*ErrorDocument) ProtoMessage 

func (*ErrorDocument) ProtoMessage()

func (*ErrorDocument) ProtoReflect added in v1.10.7 

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

func (*ErrorDocument) Reset 

func (x *ErrorDocument) Reset()

func (*ErrorDocument) String 

func (x *ErrorDocument) String() string

type ExecutionError 

type ExecutionError struct {

	// Error code indicates a grouping of a type of error.
	// More Info: <Link>
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// Detailed description of the error - including stack trace.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// Full error contents accessible via a URI
	ErrorUri string                   `protobuf:"bytes,3,opt,name=error_uri,json=errorUri,proto3" json:"error_uri,omitempty"`
	Kind     ExecutionError_ErrorKind `protobuf:"varint,4,opt,name=kind,proto3,enum=flyteidl.core.ExecutionError_ErrorKind" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

Represents the error message from the execution.

func (*ExecutionError) Descriptor deprecated 

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

Deprecated: Use ExecutionError.ProtoReflect.Descriptor instead.

func (*ExecutionError) GetCode 

func (x *ExecutionError) GetCode() string

func (*ExecutionError) GetErrorUri 

func (x *ExecutionError) GetErrorUri() string

func (*ExecutionError) GetKind 

func (x *ExecutionError) GetKind() ExecutionError_ErrorKind

func (*ExecutionError) GetMessage 

func (x *ExecutionError) GetMessage() string

func (*ExecutionError) ProtoMessage 

func (*ExecutionError) ProtoMessage()

func (*ExecutionError) ProtoReflect added in v1.10.7 

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

func (*ExecutionError) Reset 

func (x *ExecutionError) Reset()

func (*ExecutionError) String 

func (x *ExecutionError) String() string

type ExecutionError_ErrorKind 

type ExecutionError_ErrorKind int32

Error type: System or User 

const (
	ExecutionError_UNKNOWN ExecutionError_ErrorKind = 0
	ExecutionError_USER    ExecutionError_ErrorKind = 1
	ExecutionError_SYSTEM  ExecutionError_ErrorKind = 2
)

func (ExecutionError_ErrorKind) Descriptor added in v1.10.7 

func (ExecutionError_ErrorKind) Descriptor() protoreflect.EnumDescriptor

func (ExecutionError_ErrorKind) Enum added in v1.10.7 

func (x ExecutionError_ErrorKind) Enum() *ExecutionError_ErrorKind

func (ExecutionError_ErrorKind) EnumDescriptor deprecated 

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

Deprecated: Use ExecutionError_ErrorKind.Descriptor instead.

func (ExecutionError_ErrorKind) Number added in v1.10.7 

func (x ExecutionError_ErrorKind) Number() protoreflect.EnumNumber

func (ExecutionError_ErrorKind) String 

func (x ExecutionError_ErrorKind) String() string

func (ExecutionError_ErrorKind) Type added in v1.10.7 

func (ExecutionError_ErrorKind) Type() protoreflect.EnumType

type ExecutionMetricResult added in v1.10.7 

type ExecutionMetricResult struct {

	// The metric this data represents. e.g. EXECUTION_METRIC_USED_CPU_AVG or EXECUTION_METRIC_USED_MEMORY_BYTES_AVG.
	Metric string `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	// The result data in prometheus range query result format
	// https://prometheus.io/docs/prometheus/latest/querying/api/#expression-query-result-formats.
	// This may include multiple time series, differentiated by their metric labels.
	// Start time is greater of (execution attempt start, 48h ago)
	// End time is lesser of (execution attempt end, now)
	Data *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

ExecutionMetrics is a collection of metrics that are collected during the execution of a Flyte task.

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

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

Deprecated: Use ExecutionMetricResult.ProtoReflect.Descriptor instead.

func (*ExecutionMetricResult) GetData added in v1.10.7 

func (x *ExecutionMetricResult) GetData() *structpb.Struct

func (*ExecutionMetricResult) GetMetric added in v1.10.7 

func (x *ExecutionMetricResult) GetMetric() string

func (*ExecutionMetricResult) ProtoMessage added in v1.10.7 

func (*ExecutionMetricResult) ProtoMessage()

func (*ExecutionMetricResult) ProtoReflect added in v1.10.7 

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

func (*ExecutionMetricResult) Reset added in v1.10.7 

func (x *ExecutionMetricResult) Reset()

func (*ExecutionMetricResult) String added in v1.10.7 

func (x *ExecutionMetricResult) String() string

type ExtendedResources added in v1.9.20 

type ExtendedResources struct {

	// GPU accelerator to select for task. Contains information about device type, and
	// for multi-instance GPUs, the partition size to use.
	GpuAccelerator *GPUAccelerator `protobuf:"bytes,1,opt,name=gpu_accelerator,json=gpuAccelerator,proto3" json:"gpu_accelerator,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates all non-standard resources, not captured by v1.ResourceRequirements, to allocate to a task.

func (*ExtendedResources) Descriptor deprecated added in v1.9.20 

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

Deprecated: Use ExtendedResources.ProtoReflect.Descriptor instead.

func (*ExtendedResources) GetGpuAccelerator added in v1.9.20 

func (x *ExtendedResources) GetGpuAccelerator() *GPUAccelerator

func (*ExtendedResources) ProtoMessage added in v1.9.20 

func (*ExtendedResources) ProtoMessage()

func (*ExtendedResources) ProtoReflect added in v1.10.7 

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

func (*ExtendedResources) Reset added in v1.9.20 

func (x *ExtendedResources) Reset()

func (*ExtendedResources) String added in v1.9.20 

func (x *ExtendedResources) String() string

type GPUAccelerator added in v1.9.20 

type GPUAccelerator struct {

	// This can be any arbitrary string, and should be informed by the labels or taints
	// associated with the nodes in question. Default cloud provider labels typically
	// use the following values: `nvidia-tesla-t4`, `nvidia-tesla-a100`, etc.
	Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	// Types that are assignable to PartitionSizeValue:
	//
	//	*GPUAccelerator_Unpartitioned
	//	*GPUAccelerator_PartitionSize
	PartitionSizeValue isGPUAccelerator_PartitionSizeValue `protobuf_oneof:"partition_size_value"`
	// contains filtered or unexported fields
}

Metadata associated with the GPU accelerator to allocate to a task. Contains information about device type, and for multi-instance GPUs, the partition size to use.

func (*GPUAccelerator) Descriptor deprecated added in v1.9.20 

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

Deprecated: Use GPUAccelerator.ProtoReflect.Descriptor instead.

func (*GPUAccelerator) GetDevice added in v1.9.20 

func (x *GPUAccelerator) GetDevice() string

func (*GPUAccelerator) GetPartitionSize added in v1.9.20 

func (x *GPUAccelerator) GetPartitionSize() string

func (*GPUAccelerator) GetPartitionSizeValue added in v1.9.20 

func (m *GPUAccelerator) GetPartitionSizeValue() isGPUAccelerator_PartitionSizeValue

func (*GPUAccelerator) GetUnpartitioned added in v1.9.20 

func (x *GPUAccelerator) GetUnpartitioned() bool

func (*GPUAccelerator) ProtoMessage added in v1.9.20 

func (*GPUAccelerator) ProtoMessage()

func (*GPUAccelerator) ProtoReflect added in v1.10.7 

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

func (*GPUAccelerator) Reset added in v1.9.20 

func (x *GPUAccelerator) Reset()

func (*GPUAccelerator) String added in v1.9.20 

func (x *GPUAccelerator) String() string

type GPUAccelerator_PartitionSize added in v1.9.20 

type GPUAccelerator_PartitionSize struct {
	// Like `device`, this can be any arbitrary string, and should be informed by
	// the labels or taints associated with the nodes in question. Default cloud
	// provider labels typically use the following values: `1g.5gb`, `2g.10gb`, etc.
	PartitionSize string `protobuf:"bytes,3,opt,name=partition_size,json=partitionSize,proto3,oneof"`
}

type GPUAccelerator_Unpartitioned added in v1.9.20 

type GPUAccelerator_Unpartitioned struct {
	Unpartitioned bool `protobuf:"varint,2,opt,name=unpartitioned,proto3,oneof"`
}

type GateNode 

type GateNode struct {

	// Types that are assignable to Condition:
	//
	//	*GateNode_Approve
	//	*GateNode_Signal
	//	*GateNode_Sleep
	Condition isGateNode_Condition `protobuf_oneof:"condition"`
	// contains filtered or unexported fields
}

GateNode refers to the condition that is required for the gate to successfully complete.

func (*GateNode) Descriptor deprecated 

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

Deprecated: Use GateNode.ProtoReflect.Descriptor instead.

func (*GateNode) GetApprove 

func (x *GateNode) GetApprove() *ApproveCondition

func (*GateNode) GetCondition 

func (m *GateNode) GetCondition() isGateNode_Condition

func (*GateNode) GetSignal 

func (x *GateNode) GetSignal() *SignalCondition

func (*GateNode) GetSleep 

func (x *GateNode) GetSleep() *SleepCondition

func (*GateNode) ProtoMessage 

func (*GateNode) ProtoMessage()

func (*GateNode) ProtoReflect added in v1.10.7 

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

func (*GateNode) Reset 

func (x *GateNode) Reset()

func (*GateNode) String 

func (x *GateNode) String() string

type GateNode_Approve 

type GateNode_Approve struct {
	// ApproveCondition represents a dependency on an external approval provided by a boolean signal.
	Approve *ApproveCondition `protobuf:"bytes,1,opt,name=approve,proto3,oneof"`
}

type GateNode_Signal 

type GateNode_Signal struct {
	// SignalCondition represents a dependency on an signal.
	Signal *SignalCondition `protobuf:"bytes,2,opt,name=signal,proto3,oneof"`
}

type GateNode_Sleep 

type GateNode_Sleep struct {
	// SleepCondition represents a dependency on waiting for the specified duration.
	Sleep *SleepCondition `protobuf:"bytes,3,opt,name=sleep,proto3,oneof"`
}

type Granularity added in v1.11.0 

type Granularity int32
const (
	Granularity_UNSET  Granularity = 0
	Granularity_MINUTE Granularity = 1
	Granularity_HOUR   Granularity = 2
	Granularity_DAY    Granularity = 3 // default
	Granularity_MONTH  Granularity = 4
)

func (Granularity) Descriptor added in v1.11.0 

func (Granularity) Descriptor() protoreflect.EnumDescriptor

func (Granularity) Enum added in v1.11.0 

func (x Granularity) Enum() *Granularity

func (Granularity) EnumDescriptor deprecated added in v1.11.0 

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

Deprecated: Use Granularity.Descriptor instead.

func (Granularity) Number added in v1.11.0 

func (x Granularity) Number() protoreflect.EnumNumber

func (Granularity) String added in v1.11.0 

func (x Granularity) String() string

func (Granularity) Type added in v1.11.0 

func (Granularity) Type() protoreflect.EnumType

type IOStrategy 

type IOStrategy struct {

	// Mode to use to manage downloads
	DownloadMode IOStrategy_DownloadMode `` /* 141-byte string literal not displayed */
	// Mode to use to manage uploads
	UploadMode IOStrategy_UploadMode `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

Strategy to use when dealing with Blob, Schema, or multipart blob data (large datasets)

func (*IOStrategy) Descriptor deprecated 

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

Deprecated: Use IOStrategy.ProtoReflect.Descriptor instead.

func (*IOStrategy) GetDownloadMode 

func (x *IOStrategy) GetDownloadMode() IOStrategy_DownloadMode

func (*IOStrategy) GetUploadMode 

func (x *IOStrategy) GetUploadMode() IOStrategy_UploadMode

func (*IOStrategy) ProtoMessage 

func (*IOStrategy) ProtoMessage()

func (*IOStrategy) ProtoReflect added in v1.10.7 

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

func (*IOStrategy) Reset 

func (x *IOStrategy) Reset()

func (*IOStrategy) String 

func (x *IOStrategy) String() string

type IOStrategy_DownloadMode 

type IOStrategy_DownloadMode int32

Mode to use for downloading 

const (
	// All data will be downloaded before the main container is executed
	IOStrategy_DOWNLOAD_EAGER IOStrategy_DownloadMode = 0
	// Data will be downloaded as a stream and an End-Of-Stream marker will be written to indicate all data has been downloaded. Refer to protocol for details
	IOStrategy_DOWNLOAD_STREAM IOStrategy_DownloadMode = 1
	// Large objects (offloaded) will not be downloaded
	IOStrategy_DO_NOT_DOWNLOAD IOStrategy_DownloadMode = 2
)

func (IOStrategy_DownloadMode) Descriptor added in v1.10.7 

func (IOStrategy_DownloadMode) Descriptor() protoreflect.EnumDescriptor

func (IOStrategy_DownloadMode) Enum added in v1.10.7 

func (x IOStrategy_DownloadMode) Enum() *IOStrategy_DownloadMode

func (IOStrategy_DownloadMode) EnumDescriptor deprecated 

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

Deprecated: Use IOStrategy_DownloadMode.Descriptor instead.

func (IOStrategy_DownloadMode) Number added in v1.10.7 

func (x IOStrategy_DownloadMode) Number() protoreflect.EnumNumber

func (IOStrategy_DownloadMode) String 

func (x IOStrategy_DownloadMode) String() string

func (IOStrategy_DownloadMode) Type added in v1.10.7 

func (IOStrategy_DownloadMode) Type() protoreflect.EnumType

type IOStrategy_UploadMode 

type IOStrategy_UploadMode int32

Mode to use for uploading 

const (
	// All data will be uploaded after the main container exits
	IOStrategy_UPLOAD_ON_EXIT IOStrategy_UploadMode = 0
	// Data will be uploaded as it appears. Refer to protocol specification for details
	IOStrategy_UPLOAD_EAGER IOStrategy_UploadMode = 1
	// Data will not be uploaded, only references will be written
	IOStrategy_DO_NOT_UPLOAD IOStrategy_UploadMode = 2
)

func (IOStrategy_UploadMode) Descriptor added in v1.10.7 

func (IOStrategy_UploadMode) Descriptor() protoreflect.EnumDescriptor

func (IOStrategy_UploadMode) Enum added in v1.10.7 

func (x IOStrategy_UploadMode) Enum() *IOStrategy_UploadMode

func (IOStrategy_UploadMode) EnumDescriptor deprecated 

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

Deprecated: Use IOStrategy_UploadMode.Descriptor instead.

func (IOStrategy_UploadMode) Number added in v1.10.7 

func (x IOStrategy_UploadMode) Number() protoreflect.EnumNumber

func (IOStrategy_UploadMode) String 

func (x IOStrategy_UploadMode) String() string

func (IOStrategy_UploadMode) Type added in v1.10.7 

func (IOStrategy_UploadMode) Type() protoreflect.EnumType

type Identifier 

type Identifier struct {

	// Identifies the specific type of resource that this identifier corresponds to.
	ResourceType ResourceType `` /* 130-byte string literal not displayed */
	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,3,opt,name=domain,proto3" json:"domain,omitempty"`
	// User provided value for the resource.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Specific version of the resource.
	Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,6,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Encapsulation of fields that uniquely identifies a Flyte resource.

func (*Identifier) Descriptor deprecated 

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

Deprecated: Use Identifier.ProtoReflect.Descriptor instead.

func (*Identifier) GetDomain 

func (x *Identifier) GetDomain() string

func (*Identifier) GetName 

func (x *Identifier) GetName() string

func (*Identifier) GetOrg added in v1.10.7 

func (x *Identifier) GetOrg() string

func (*Identifier) GetProject 

func (x *Identifier) GetProject() string

func (*Identifier) GetResourceType 

func (x *Identifier) GetResourceType() ResourceType

func (*Identifier) GetVersion 

func (x *Identifier) GetVersion() string

func (*Identifier) ProtoMessage 

func (*Identifier) ProtoMessage()

func (*Identifier) ProtoReflect added in v1.10.7 

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

func (*Identifier) Reset 

func (x *Identifier) Reset()

func (*Identifier) String 

func (x *Identifier) String() string

type Identity 

type Identity struct {

	// iam_role references the fully qualified name of Identity & Access Management role to impersonate.
	IamRole string `protobuf:"bytes,1,opt,name=iam_role,json=iamRole,proto3" json:"iam_role,omitempty"`
	// k8s_service_account references a kubernetes service account to impersonate.
	K8SServiceAccount string `protobuf:"bytes,2,opt,name=k8s_service_account,json=k8sServiceAccount,proto3" json:"k8s_service_account,omitempty"`
	// oauth2_client references an oauth2 client. Backend plugins can use this information to impersonate the client when
	// making external calls.
	Oauth2Client *OAuth2Client `protobuf:"bytes,3,opt,name=oauth2_client,json=oauth2Client,proto3" json:"oauth2_client,omitempty"`
	// execution_identity references the subject who makes the execution
	ExecutionIdentity string `protobuf:"bytes,4,opt,name=execution_identity,json=executionIdentity,proto3" json:"execution_identity,omitempty"`
	// contains filtered or unexported fields
}

Identity encapsulates the various security identities a task can run as. It's up to the underlying plugin to pick the right identity for the execution environment.

func (*Identity) Descriptor deprecated 

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

Deprecated: Use Identity.ProtoReflect.Descriptor instead.

func (*Identity) GetExecutionIdentity 

func (x *Identity) GetExecutionIdentity() string

func (*Identity) GetIamRole 

func (x *Identity) GetIamRole() string

func (*Identity) GetK8SServiceAccount 

func (x *Identity) GetK8SServiceAccount() string

func (*Identity) GetOauth2Client 

func (x *Identity) GetOauth2Client() *OAuth2Client

func (*Identity) ProtoMessage 

func (*Identity) ProtoMessage()

func (*Identity) ProtoReflect added in v1.10.7 

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

func (*Identity) Reset 

func (x *Identity) Reset()

func (*Identity) String 

func (x *Identity) String() string

type IfBlock 

type IfBlock struct {
	Condition *BooleanExpression `protobuf:"bytes,1,opt,name=condition,proto3" json:"condition,omitempty"`
	ThenNode  *Node              `protobuf:"bytes,2,opt,name=then_node,json=thenNode,proto3" json:"then_node,omitempty"`
	// contains filtered or unexported fields
}

Defines a condition and the execution unit that should be executed if the condition is satisfied.

func (*IfBlock) Descriptor deprecated 

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

Deprecated: Use IfBlock.ProtoReflect.Descriptor instead.

func (*IfBlock) GetCondition 

func (x *IfBlock) GetCondition() *BooleanExpression

func (*IfBlock) GetThenNode 

func (x *IfBlock) GetThenNode() *Node

func (*IfBlock) ProtoMessage 

func (*IfBlock) ProtoMessage()

func (*IfBlock) ProtoReflect added in v1.10.7 

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

func (*IfBlock) Reset 

func (x *IfBlock) Reset()

func (*IfBlock) String 

func (x *IfBlock) String() string

type IfElseBlock 

type IfElseBlock struct {

	// +required. First condition to evaluate.
	Case *IfBlock `protobuf:"bytes,1,opt,name=case,proto3" json:"case,omitempty"`
	// +optional. Additional branches to evaluate.
	Other []*IfBlock `protobuf:"bytes,2,rep,name=other,proto3" json:"other,omitempty"`
	// +required.
	//
	// Types that are assignable to Default:
	//
	//	*IfElseBlock_ElseNode
	//	*IfElseBlock_Error
	Default isIfElseBlock_Default `protobuf_oneof:"default"`
	// contains filtered or unexported fields
}

Defines a series of if/else blocks. The first branch whose condition evaluates to true is the one to execute. If no conditions were satisfied, the else_node or the error will execute.

func (*IfElseBlock) Descriptor deprecated 

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

Deprecated: Use IfElseBlock.ProtoReflect.Descriptor instead.

func (*IfElseBlock) GetCase 

func (x *IfElseBlock) GetCase() *IfBlock

func (*IfElseBlock) GetDefault 

func (m *IfElseBlock) GetDefault() isIfElseBlock_Default

func (*IfElseBlock) GetElseNode 

func (x *IfElseBlock) GetElseNode() *Node

func (*IfElseBlock) GetError 

func (x *IfElseBlock) GetError() *Error

func (*IfElseBlock) GetOther 

func (x *IfElseBlock) GetOther() []*IfBlock

func (*IfElseBlock) ProtoMessage 

func (*IfElseBlock) ProtoMessage()

func (*IfElseBlock) ProtoReflect added in v1.10.7 

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

func (*IfElseBlock) Reset 

func (x *IfElseBlock) Reset()

func (*IfElseBlock) String 

func (x *IfElseBlock) String() string

type IfElseBlock_ElseNode 

type IfElseBlock_ElseNode struct {
	// The node to execute in case none of the branches were taken.
	ElseNode *Node `protobuf:"bytes,3,opt,name=else_node,json=elseNode,proto3,oneof"`
}

type IfElseBlock_Error 

type IfElseBlock_Error struct {
	// An error to throw in case none of the branches were taken.
	Error *Error `protobuf:"bytes,4,opt,name=error,proto3,oneof"`
}

type InputBindingData added in v1.10.7 

type InputBindingData struct {
	Var string `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use InputBindingData.ProtoReflect.Descriptor instead.

func (*InputBindingData) GetVar added in v1.10.7 

func (x *InputBindingData) GetVar() string

func (*InputBindingData) ProtoMessage added in v1.10.7 

func (*InputBindingData) ProtoMessage()

func (*InputBindingData) ProtoReflect added in v1.10.7 

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

func (*InputBindingData) Reset added in v1.10.7 

func (x *InputBindingData) Reset()

func (*InputBindingData) String added in v1.10.7 

func (x *InputBindingData) String() string

type K8SObjectMetadata 

type K8SObjectMetadata struct {

	// Optional labels to add to the pod definition.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Optional annotations to add to the pod definition.
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Metadata for building a kubernetes object when a task is executed.

func (*K8SObjectMetadata) Descriptor deprecated 

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

Deprecated: Use K8SObjectMetadata.ProtoReflect.Descriptor instead.

func (*K8SObjectMetadata) GetAnnotations 

func (x *K8SObjectMetadata) GetAnnotations() map[string]string

func (*K8SObjectMetadata) GetLabels 

func (x *K8SObjectMetadata) GetLabels() map[string]string

func (*K8SObjectMetadata) ProtoMessage 

func (*K8SObjectMetadata) ProtoMessage()

func (*K8SObjectMetadata) ProtoReflect added in v1.10.7 

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

func (*K8SObjectMetadata) Reset 

func (x *K8SObjectMetadata) Reset()

func (*K8SObjectMetadata) String 

func (x *K8SObjectMetadata) String() string

type K8SPod 

type K8SPod struct {

	// Contains additional metadata for building a kubernetes pod.
	Metadata *K8SObjectMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Defines the primary pod spec created when a task is executed.
	// This should be a JSON-marshalled pod spec, which can be defined in
	// - go, using: https://github.com/kubernetes/api/blob/release-1.21/core/v1/types.go#L2936
	// - python: using https://github.com/kubernetes-client/python/blob/release-19.0/kubernetes/client/models/v1_pod_spec.py
	PodSpec *structpb.Struct `protobuf:"bytes,2,opt,name=pod_spec,json=podSpec,proto3" json:"pod_spec,omitempty"`
	// BETA: Optional configuration for DataLoading. If not specified, then default values are used.
	// This makes it possible to to run a completely portable container, that uses inputs and outputs
	// only from the local file-system and without having any reference to flytekit. This is supported only on K8s at the moment.
	// If data loading is enabled, then data will be mounted in accompanying directories specified in the DataLoadingConfig. If the directories
	// are not specified, inputs will be mounted onto and outputs will be uploaded from a pre-determined file-system path. Refer to the documentation
	// to understand the default paths.
	// Only K8s
	DataConfig *DataLoadingConfig `protobuf:"bytes,3,opt,name=data_config,json=dataConfig,proto3" json:"data_config,omitempty"`
	// contains filtered or unexported fields
}

Defines a pod spec and additional pod metadata that is created when a task is executed.

func (*K8SPod) Descriptor deprecated 

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

Deprecated: Use K8SPod.ProtoReflect.Descriptor instead.

func (*K8SPod) GetDataConfig 

func (x *K8SPod) GetDataConfig() *DataLoadingConfig

func (*K8SPod) GetMetadata 

func (x *K8SPod) GetMetadata() *K8SObjectMetadata

func (*K8SPod) GetPodSpec 

func (x *K8SPod) GetPodSpec() *structpb.Struct

func (*K8SPod) ProtoMessage 

func (*K8SPod) ProtoMessage()

func (*K8SPod) ProtoReflect added in v1.10.7 

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

func (*K8SPod) Reset 

func (x *K8SPod) Reset()

func (*K8SPod) String 

func (x *K8SPod) String() string

type KeyValuePair 

type KeyValuePair struct {

	// required.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// +optional.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

A generic key value pair.

func (*KeyValuePair) Descriptor deprecated 

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

Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.

func (*KeyValuePair) GetKey 

func (x *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (x *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) ProtoReflect added in v1.10.7 

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

func (*KeyValuePair) Reset 

func (x *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (x *KeyValuePair) String() string

type LabelValue added in v1.10.7 

type LabelValue struct {

	// Types that are assignable to Value:
	//
	//	*LabelValue_StaticValue
	//	*LabelValue_TimeValue
	//	*LabelValue_TriggeredBinding
	//	*LabelValue_InputBinding
	//	*LabelValue_RuntimeBinding
	Value isLabelValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use LabelValue.ProtoReflect.Descriptor instead.

func (*LabelValue) GetInputBinding added in v1.10.7 

func (x *LabelValue) GetInputBinding() *InputBindingData

func (*LabelValue) GetRuntimeBinding added in v1.11.0 

func (x *LabelValue) GetRuntimeBinding() *RuntimeBinding

func (*LabelValue) GetStaticValue added in v1.10.7 

func (x *LabelValue) GetStaticValue() string

func (*LabelValue) GetTimeValue added in v1.10.7 

func (x *LabelValue) GetTimeValue() *timestamppb.Timestamp

func (*LabelValue) GetTriggeredBinding added in v1.10.7 

func (x *LabelValue) GetTriggeredBinding() *ArtifactBindingData

func (*LabelValue) GetValue added in v1.10.7 

func (m *LabelValue) GetValue() isLabelValue_Value

func (*LabelValue) ProtoMessage added in v1.10.7 

func (*LabelValue) ProtoMessage()

func (*LabelValue) ProtoReflect added in v1.10.7 

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

func (*LabelValue) Reset added in v1.10.7 

func (x *LabelValue) Reset()

func (*LabelValue) String added in v1.10.7 

func (x *LabelValue) String() string

type LabelValue_InputBinding added in v1.10.7 

type LabelValue_InputBinding struct {
	InputBinding *InputBindingData `protobuf:"bytes,4,opt,name=input_binding,json=inputBinding,proto3,oneof"`
}

type LabelValue_RuntimeBinding added in v1.11.0 

type LabelValue_RuntimeBinding struct {
	RuntimeBinding *RuntimeBinding `protobuf:"bytes,5,opt,name=runtime_binding,json=runtimeBinding,proto3,oneof"`
}

type LabelValue_StaticValue added in v1.10.7 

type LabelValue_StaticValue struct {
	// The string static value is for use in the Partitions object
	StaticValue string `protobuf:"bytes,1,opt,name=static_value,json=staticValue,proto3,oneof"`
}

type LabelValue_TimeValue added in v1.10.7 

type LabelValue_TimeValue struct {
	// The time value is for use in the TimePartition case
	TimeValue *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time_value,json=timeValue,proto3,oneof"`
}

type LabelValue_TriggeredBinding added in v1.10.7 

type LabelValue_TriggeredBinding struct {
	TriggeredBinding *ArtifactBindingData `protobuf:"bytes,3,opt,name=triggered_binding,json=triggeredBinding,proto3,oneof"`
}

type LaunchPlanTemplate added in v1.10.7 

type LaunchPlanTemplate struct {

	// A globally unique identifier for the launch plan.
	Id *Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The input and output interface for the launch plan
	Interface *TypedInterface `protobuf:"bytes,2,opt,name=interface,proto3" json:"interface,omitempty"`
	// A collection of input literals that are fixed for the launch plan
	FixedInputs *LiteralMap `protobuf:"bytes,3,opt,name=fixed_inputs,json=fixedInputs,proto3" json:"fixed_inputs,omitempty"`
	// contains filtered or unexported fields
}

A structure that uniquely identifies a launch plan in the system.

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

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

Deprecated: Use LaunchPlanTemplate.ProtoReflect.Descriptor instead.

func (*LaunchPlanTemplate) GetFixedInputs added in v1.11.0 

func (x *LaunchPlanTemplate) GetFixedInputs() *LiteralMap

func (*LaunchPlanTemplate) GetId added in v1.10.7 

func (x *LaunchPlanTemplate) GetId() *Identifier

func (*LaunchPlanTemplate) GetInterface added in v1.10.7 

func (x *LaunchPlanTemplate) GetInterface() *TypedInterface

func (*LaunchPlanTemplate) ProtoMessage added in v1.10.7 

func (*LaunchPlanTemplate) ProtoMessage()

func (*LaunchPlanTemplate) ProtoReflect added in v1.10.7 

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

func (*LaunchPlanTemplate) Reset added in v1.10.7 

func (x *LaunchPlanTemplate) Reset()

func (*LaunchPlanTemplate) String added in v1.10.7 

func (x *LaunchPlanTemplate) String() string

type Literal 

type Literal struct {

	// Types that are assignable to Value:
	//
	//	*Literal_Scalar
	//	*Literal_Collection
	//	*Literal_Map
	Value isLiteral_Value `protobuf_oneof:"value"`
	// A hash representing this literal.
	// This is used for caching purposes. For more details refer to RFC 1893
	// (https://github.com/flyteorg/flyte/blob/master/rfc/system/1893-caching-of-offloaded-objects.md)
	Hash string `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"`
	// Additional metadata for literals.
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

A simple value. This supports any level of nesting (e.g. array of array of array of Blobs) as well as simple primitives.

func (*Literal) Descriptor deprecated 

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

Deprecated: Use Literal.ProtoReflect.Descriptor instead.

func (*Literal) GetCollection 

func (x *Literal) GetCollection() *LiteralCollection

func (*Literal) GetHash 

func (x *Literal) GetHash() string

func (*Literal) GetMap 

func (x *Literal) GetMap() *LiteralMap

func (*Literal) GetMetadata added in v1.10.7 

func (x *Literal) GetMetadata() map[string]string

func (*Literal) GetScalar 

func (x *Literal) GetScalar() *Scalar

func (*Literal) GetValue 

func (m *Literal) GetValue() isLiteral_Value

func (*Literal) ProtoMessage 

func (*Literal) ProtoMessage()

func (*Literal) ProtoReflect added in v1.10.7 

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

func (*Literal) Reset 

func (x *Literal) Reset()

func (*Literal) String 

func (x *Literal) String() string

type LiteralCollection 

type LiteralCollection struct {
	Literals []*Literal `protobuf:"bytes,1,rep,name=literals,proto3" json:"literals,omitempty"`
	// contains filtered or unexported fields
}

A collection of literals. This is a workaround since oneofs in proto messages cannot contain a repeated field.

func (*LiteralCollection) Descriptor deprecated 

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

Deprecated: Use LiteralCollection.ProtoReflect.Descriptor instead.

func (*LiteralCollection) GetLiterals 

func (x *LiteralCollection) GetLiterals() []*Literal

func (*LiteralCollection) ProtoMessage 

func (*LiteralCollection) ProtoMessage()

func (*LiteralCollection) ProtoReflect added in v1.10.7 

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

func (*LiteralCollection) Reset 

func (x *LiteralCollection) Reset()

func (*LiteralCollection) String 

func (x *LiteralCollection) String() string

type LiteralMap 

type LiteralMap struct {
	Literals map[string]*Literal `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

A map of literals. This is a workaround since oneofs in proto messages cannot contain a repeated field.

func (*LiteralMap) Descriptor deprecated 

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

Deprecated: Use LiteralMap.ProtoReflect.Descriptor instead.

func (*LiteralMap) GetLiterals 

func (x *LiteralMap) GetLiterals() map[string]*Literal

func (*LiteralMap) ProtoMessage 

func (*LiteralMap) ProtoMessage()

func (*LiteralMap) ProtoReflect added in v1.10.7 

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

func (*LiteralMap) Reset 

func (x *LiteralMap) Reset()

func (*LiteralMap) String 

func (x *LiteralMap) String() string

type LiteralType 

type LiteralType struct {

	// Types that are assignable to Type:
	//
	//	*LiteralType_Simple
	//	*LiteralType_Schema
	//	*LiteralType_CollectionType
	//	*LiteralType_MapValueType
	//	*LiteralType_Blob
	//	*LiteralType_EnumType
	//	*LiteralType_StructuredDatasetType
	//	*LiteralType_UnionType
	Type isLiteralType_Type `protobuf_oneof:"type"`
	// This field contains type metadata that is descriptive of the type, but is NOT considered in type-checking.  This might be used by
	// consumers to identify special behavior or display extended information for the type.
	Metadata *structpb.Struct `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// This field contains arbitrary data that might have special semantic
	// meaning for the client but does not effect internal flyte behavior.
	Annotation *TypeAnnotation `protobuf:"bytes,9,opt,name=annotation,proto3" json:"annotation,omitempty"`
	// Hints to improve type matching.
	Structure *TypeStructure `protobuf:"bytes,11,opt,name=structure,proto3" json:"structure,omitempty"`
	// contains filtered or unexported fields
}

Defines a strong type to allow type checking between interfaces.

func (*LiteralType) Descriptor deprecated 

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

Deprecated: Use LiteralType.ProtoReflect.Descriptor instead.

func (*LiteralType) GetAnnotation 

func (x *LiteralType) GetAnnotation() *TypeAnnotation

func (*LiteralType) GetBlob 

func (x *LiteralType) GetBlob() *BlobType

func (*LiteralType) GetCollectionType 

func (x *LiteralType) GetCollectionType() *LiteralType

func (*LiteralType) GetEnumType 

func (x *LiteralType) GetEnumType() *EnumType

func (*LiteralType) GetMapValueType 

func (x *LiteralType) GetMapValueType() *LiteralType

func (*LiteralType) GetMetadata 

func (x *LiteralType) GetMetadata() *structpb.Struct

func (*LiteralType) GetSchema 

func (x *LiteralType) GetSchema() *SchemaType

func (*LiteralType) GetSimple 

func (x *LiteralType) GetSimple() SimpleType

func (*LiteralType) GetStructure 

func (x *LiteralType) GetStructure() *TypeStructure

func (*LiteralType) GetStructuredDatasetType 

func (x *LiteralType) GetStructuredDatasetType() *StructuredDatasetType

func (*LiteralType) GetType 

func (m *LiteralType) GetType() isLiteralType_Type

func (*LiteralType) GetUnionType 

func (x *LiteralType) GetUnionType() *UnionType

func (*LiteralType) ProtoMessage 

func (*LiteralType) ProtoMessage()

func (*LiteralType) ProtoReflect added in v1.10.7 

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

func (*LiteralType) Reset 

func (x *LiteralType) Reset()

func (*LiteralType) String 

func (x *LiteralType) String() string

type LiteralType_Blob 

type LiteralType_Blob struct {
	// A blob might have specialized implementation details depending on associated metadata.
	Blob *BlobType `protobuf:"bytes,5,opt,name=blob,proto3,oneof"`
}

type LiteralType_CollectionType 

type LiteralType_CollectionType struct {
	// Defines the type of the value of a collection. Only homogeneous collections are allowed.
	CollectionType *LiteralType `protobuf:"bytes,3,opt,name=collection_type,json=collectionType,proto3,oneof"`
}

type LiteralType_EnumType 

type LiteralType_EnumType struct {
	// Defines an enum with pre-defined string values.
	EnumType *EnumType `protobuf:"bytes,7,opt,name=enum_type,json=enumType,proto3,oneof"`
}

type LiteralType_MapValueType 

type LiteralType_MapValueType struct {
	// Defines the type of the value of a map type. The type of the key is always a string.
	MapValueType *LiteralType `protobuf:"bytes,4,opt,name=map_value_type,json=mapValueType,proto3,oneof"`
}

type LiteralType_Schema 

type LiteralType_Schema struct {
	// A complex type that requires matching of inner fields.
	Schema *SchemaType `protobuf:"bytes,2,opt,name=schema,proto3,oneof"`
}

type LiteralType_Simple 

type LiteralType_Simple struct {
	// A simple type that can be compared one-to-one with another.
	Simple SimpleType `protobuf:"varint,1,opt,name=simple,proto3,enum=flyteidl.core.SimpleType,oneof"`
}

type LiteralType_StructuredDatasetType 

type LiteralType_StructuredDatasetType struct {
	// Generalized schema support
	StructuredDatasetType *StructuredDatasetType `protobuf:"bytes,8,opt,name=structured_dataset_type,json=structuredDatasetType,proto3,oneof"`
}

type LiteralType_UnionType 

type LiteralType_UnionType struct {
	// Defines an union type with pre-defined LiteralTypes.
	UnionType *UnionType `protobuf:"bytes,10,opt,name=union_type,json=unionType,proto3,oneof"`
}

type Literal_Collection 

type Literal_Collection struct {
	// A collection of literals to allow nesting.
	Collection *LiteralCollection `protobuf:"bytes,2,opt,name=collection,proto3,oneof"`
}

type Literal_Map 

type Literal_Map struct {
	// A map of strings to literals.
	Map *LiteralMap `protobuf:"bytes,3,opt,name=map,proto3,oneof"`
}

type Literal_Scalar 

type Literal_Scalar struct {
	// A simple value.
	Scalar *Scalar `protobuf:"bytes,1,opt,name=scalar,proto3,oneof"`
}

type Node 

type Node struct {

	// A workflow-level unique identifier that identifies this node in the workflow. 'inputs' and 'outputs' are reserved
	// node ids that cannot be used by other nodes.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Extra metadata about the node.
	Metadata *NodeMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Specifies how to bind the underlying interface's inputs. All required inputs specified in the underlying interface
	// must be fulfilled.
	Inputs []*Binding `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// +optional Specifies execution dependency for this node ensuring it will only get scheduled to run after all its
	// upstream nodes have completed. This node will have an implicit dependency on any node that appears in inputs
	// field.
	UpstreamNodeIds []string `protobuf:"bytes,4,rep,name=upstream_node_ids,json=upstreamNodeIds,proto3" json:"upstream_node_ids,omitempty"`
	// +optional. A node can define aliases for a subset of its outputs. This is particularly useful if different nodes
	// need to conform to the same interface (e.g. all branches in a branch node). Downstream nodes must refer to this
	// nodes outputs using the alias if one's specified.
	OutputAliases []*Alias `protobuf:"bytes,5,rep,name=output_aliases,json=outputAliases,proto3" json:"output_aliases,omitempty"`
	// Information about the target to execute in this node.
	//
	// Types that are assignable to Target:
	//
	//	*Node_TaskNode
	//	*Node_WorkflowNode
	//	*Node_BranchNode
	//	*Node_GateNode
	//	*Node_ArrayNode
	Target isNode_Target `protobuf_oneof:"target"`
	// contains filtered or unexported fields
}

A Workflow graph Node. One unit of execution in the graph. Each node can be linked to a Task, a Workflow or a branch node.

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetArrayNode 

func (x *Node) GetArrayNode() *ArrayNode

func (*Node) GetBranchNode 

func (x *Node) GetBranchNode() *BranchNode

func (*Node) GetGateNode 

func (x *Node) GetGateNode() *GateNode

func (*Node) GetId 

func (x *Node) GetId() string

func (*Node) GetInputs 

func (x *Node) GetInputs() []*Binding

func (*Node) GetMetadata 

func (x *Node) GetMetadata() *NodeMetadata

func (*Node) GetOutputAliases 

func (x *Node) GetOutputAliases() []*Alias

func (*Node) GetTarget 

func (m *Node) GetTarget() isNode_Target

func (*Node) GetTaskNode 

func (x *Node) GetTaskNode() *TaskNode

func (*Node) GetUpstreamNodeIds 

func (x *Node) GetUpstreamNodeIds() []string

func (*Node) GetWorkflowNode 

func (x *Node) GetWorkflowNode() *WorkflowNode

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect added in v1.10.7 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type NodeExecution 

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

Indicates various phases of Node Execution that only include the time spent to run the nodes/workflows

func (*NodeExecution) Descriptor deprecated 

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

Deprecated: Use NodeExecution.ProtoReflect.Descriptor instead.

func (*NodeExecution) ProtoMessage 

func (*NodeExecution) ProtoMessage()

func (*NodeExecution) ProtoReflect added in v1.10.7 

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

func (*NodeExecution) Reset 

func (x *NodeExecution) Reset()

func (*NodeExecution) String 

func (x *NodeExecution) String() string

type NodeExecutionIdentifier 

type NodeExecutionIdentifier struct {
	NodeId      string                       `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ExecutionId *WorkflowExecutionIdentifier `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

Encapsulation of fields that identify a Flyte node execution entity.

func (*NodeExecutionIdentifier) Descriptor deprecated 

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

Deprecated: Use NodeExecutionIdentifier.ProtoReflect.Descriptor instead.

func (*NodeExecutionIdentifier) GetExecutionId 

func (x *NodeExecutionIdentifier) GetExecutionId() *WorkflowExecutionIdentifier

func (*NodeExecutionIdentifier) GetNodeId 

func (x *NodeExecutionIdentifier) GetNodeId() string

func (*NodeExecutionIdentifier) ProtoMessage 

func (*NodeExecutionIdentifier) ProtoMessage()

func (*NodeExecutionIdentifier) ProtoReflect added in v1.10.7 

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

func (*NodeExecutionIdentifier) Reset 

func (x *NodeExecutionIdentifier) Reset()

func (*NodeExecutionIdentifier) String 

func (x *NodeExecutionIdentifier) String() string

type NodeExecution_Phase 

type NodeExecution_Phase int32
const (
	NodeExecution_UNDEFINED       NodeExecution_Phase = 0
	NodeExecution_QUEUED          NodeExecution_Phase = 1
	NodeExecution_RUNNING         NodeExecution_Phase = 2
	NodeExecution_SUCCEEDED       NodeExecution_Phase = 3
	NodeExecution_FAILING         NodeExecution_Phase = 4
	NodeExecution_FAILED          NodeExecution_Phase = 5
	NodeExecution_ABORTED         NodeExecution_Phase = 6
	NodeExecution_SKIPPED         NodeExecution_Phase = 7
	NodeExecution_TIMED_OUT       NodeExecution_Phase = 8
	NodeExecution_DYNAMIC_RUNNING NodeExecution_Phase = 9
	NodeExecution_RECOVERED       NodeExecution_Phase = 10
)

func (NodeExecution_Phase) Descriptor added in v1.10.7 

func (NodeExecution_Phase) Descriptor() protoreflect.EnumDescriptor

func (NodeExecution_Phase) Enum added in v1.10.7 

func (x NodeExecution_Phase) Enum() *NodeExecution_Phase

func (NodeExecution_Phase) EnumDescriptor deprecated 

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

Deprecated: Use NodeExecution_Phase.Descriptor instead.

func (NodeExecution_Phase) Number added in v1.10.7 

func (x NodeExecution_Phase) Number() protoreflect.EnumNumber

func (NodeExecution_Phase) String 

func (x NodeExecution_Phase) String() string

func (NodeExecution_Phase) Type added in v1.10.7 

func (NodeExecution_Phase) Type() protoreflect.EnumType

type NodeMetadata 

type NodeMetadata struct {

	// A friendly name for the Node
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The overall timeout of a task.
	Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of retries per task.
	Retries *RetryStrategy `protobuf:"bytes,5,opt,name=retries,proto3" json:"retries,omitempty"`
	// Identify whether node is interruptible
	//
	// Types that are assignable to InterruptibleValue:
	//
	//	*NodeMetadata_Interruptible
	InterruptibleValue isNodeMetadata_InterruptibleValue `protobuf_oneof:"interruptible_value"`
	// Identify whether a node should have it's outputs cached.
	//
	// Types that are assignable to CacheableValue:
	//
	//	*NodeMetadata_Cacheable
	CacheableValue isNodeMetadata_CacheableValue `protobuf_oneof:"cacheable_value"`
	// The version of the cache to use.
	//
	// Types that are assignable to CacheVersionValue:
	//
	//	*NodeMetadata_CacheVersion
	CacheVersionValue isNodeMetadata_CacheVersionValue `protobuf_oneof:"cache_version_value"`
	// Identify whether caching operations involving this node should be serialized.
	//
	// Types that are assignable to CacheSerializableValue:
	//
	//	*NodeMetadata_CacheSerializable
	CacheSerializableValue isNodeMetadata_CacheSerializableValue `protobuf_oneof:"cache_serializable_value"`
	// contains filtered or unexported fields
}

Defines extra information about the Node.

func (*NodeMetadata) Descriptor deprecated 

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

Deprecated: Use NodeMetadata.ProtoReflect.Descriptor instead.

func (*NodeMetadata) GetCacheSerializable added in v1.10.7 

func (x *NodeMetadata) GetCacheSerializable() bool

func (*NodeMetadata) GetCacheSerializableValue added in v1.10.7 

func (m *NodeMetadata) GetCacheSerializableValue() isNodeMetadata_CacheSerializableValue

func (*NodeMetadata) GetCacheVersion added in v1.10.7 

func (x *NodeMetadata) GetCacheVersion() string

func (*NodeMetadata) GetCacheVersionValue added in v1.10.7 

func (m *NodeMetadata) GetCacheVersionValue() isNodeMetadata_CacheVersionValue

func (*NodeMetadata) GetCacheable added in v1.10.7 

func (x *NodeMetadata) GetCacheable() bool

func (*NodeMetadata) GetCacheableValue added in v1.10.7 

func (m *NodeMetadata) GetCacheableValue() isNodeMetadata_CacheableValue

func (*NodeMetadata) GetInterruptible 

func (x *NodeMetadata) GetInterruptible() bool

func (*NodeMetadata) GetInterruptibleValue 

func (m *NodeMetadata) GetInterruptibleValue() isNodeMetadata_InterruptibleValue

func (*NodeMetadata) GetName 

func (x *NodeMetadata) GetName() string

func (*NodeMetadata) GetRetries 

func (x *NodeMetadata) GetRetries() *RetryStrategy

func (*NodeMetadata) GetTimeout 

func (x *NodeMetadata) GetTimeout() *durationpb.Duration

func (*NodeMetadata) ProtoMessage 

func (*NodeMetadata) ProtoMessage()

func (*NodeMetadata) ProtoReflect added in v1.10.7 

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

func (*NodeMetadata) Reset 

func (x *NodeMetadata) Reset()

func (*NodeMetadata) String 

func (x *NodeMetadata) String() string

type NodeMetadata_CacheSerializable added in v1.10.7 

type NodeMetadata_CacheSerializable struct {
	CacheSerializable bool `protobuf:"varint,9,opt,name=cache_serializable,json=cacheSerializable,proto3,oneof"`
}

type NodeMetadata_CacheVersion added in v1.10.7 

type NodeMetadata_CacheVersion struct {
	CacheVersion string `protobuf:"bytes,8,opt,name=cache_version,json=cacheVersion,proto3,oneof"`
}

type NodeMetadata_Cacheable added in v1.10.7 

type NodeMetadata_Cacheable struct {
	Cacheable bool `protobuf:"varint,7,opt,name=cacheable,proto3,oneof"`
}

type NodeMetadata_Interruptible 

type NodeMetadata_Interruptible struct {
	Interruptible bool `protobuf:"varint,6,opt,name=interruptible,proto3,oneof"`
}

type Node_ArrayNode 

type Node_ArrayNode struct {
	// Information about the sub-node executions for each value in the list of this nodes
	// inputs values.
	ArrayNode *ArrayNode `protobuf:"bytes,10,opt,name=array_node,json=arrayNode,proto3,oneof"`
}

type Node_BranchNode 

type Node_BranchNode struct {
	// Information about the branch node to evaluate in this node.
	BranchNode *BranchNode `protobuf:"bytes,8,opt,name=branch_node,json=branchNode,proto3,oneof"`
}

type Node_GateNode 

type Node_GateNode struct {
	// Information about the condition to evaluate in this node.
	GateNode *GateNode `protobuf:"bytes,9,opt,name=gate_node,json=gateNode,proto3,oneof"`
}

type Node_TaskNode 

type Node_TaskNode struct {
	// Information about the Task to execute in this node.
	TaskNode *TaskNode `protobuf:"bytes,6,opt,name=task_node,json=taskNode,proto3,oneof"`
}

type Node_WorkflowNode 

type Node_WorkflowNode struct {
	// Information about the Workflow to execute in this mode.
	WorkflowNode *WorkflowNode `protobuf:"bytes,7,opt,name=workflow_node,json=workflowNode,proto3,oneof"`
}

type OAuth2Client 

type OAuth2Client struct {

	// client_id is the public id for the client to use. The system will not perform any pre-auth validation that the
	// secret requested matches the client_id indicated here.
	// +required
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// client_secret is a reference to the secret used to authenticate the OAuth2 client.
	// +required
	ClientSecret *Secret `protobuf:"bytes,2,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
	// contains filtered or unexported fields
}

OAuth2Client encapsulates OAuth2 Client Credentials to be used when making calls on behalf of that task.

func (*OAuth2Client) Descriptor deprecated 

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

Deprecated: Use OAuth2Client.ProtoReflect.Descriptor instead.

func (*OAuth2Client) GetClientId 

func (x *OAuth2Client) GetClientId() string

func (*OAuth2Client) GetClientSecret 

func (x *OAuth2Client) GetClientSecret() *Secret

func (*OAuth2Client) ProtoMessage 

func (*OAuth2Client) ProtoMessage()

func (*OAuth2Client) ProtoReflect added in v1.10.7 

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

func (*OAuth2Client) Reset 

func (x *OAuth2Client) Reset()

func (*OAuth2Client) String 

func (x *OAuth2Client) String() string

type OAuth2TokenRequest 

type OAuth2TokenRequest struct {

	// name indicates a unique id for the token request within this task token requests. It'll be used as a suffix for
	// environment variables and as a filename for mounting tokens as files.
	// +required
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// type indicates the type of the request to make. Defaults to CLIENT_CREDENTIALS.
	// +required
	Type OAuth2TokenRequest_Type `protobuf:"varint,2,opt,name=type,proto3,enum=flyteidl.core.OAuth2TokenRequest_Type" json:"type,omitempty"`
	// client references the client_id/secret to use to request the OAuth2 token.
	// +required
	Client *OAuth2Client `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	// idp_discovery_endpoint references the discovery endpoint used to retrieve token endpoint and other related
	// information.
	// +optional
	IdpDiscoveryEndpoint string `protobuf:"bytes,4,opt,name=idp_discovery_endpoint,json=idpDiscoveryEndpoint,proto3" json:"idp_discovery_endpoint,omitempty"`
	// token_endpoint references the token issuance endpoint. If idp_discovery_endpoint is not provided, this parameter is
	// mandatory.
	// +optional
	TokenEndpoint string `protobuf:"bytes,5,opt,name=token_endpoint,json=tokenEndpoint,proto3" json:"token_endpoint,omitempty"`
	// contains filtered or unexported fields
}

OAuth2TokenRequest encapsulates information needed to request an OAuth2 token. FLYTE_TOKENS_ENV_PREFIX will be passed to indicate the prefix of the environment variables that will be present if tokens are passed through environment variables. FLYTE_TOKENS_PATH_PREFIX will be passed to indicate the prefix of the path where secrets will be mounted if tokens are passed through file mounts.

func (*OAuth2TokenRequest) Descriptor deprecated 

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

Deprecated: Use OAuth2TokenRequest.ProtoReflect.Descriptor instead.

func (*OAuth2TokenRequest) GetClient 

func (x *OAuth2TokenRequest) GetClient() *OAuth2Client

func (*OAuth2TokenRequest) GetIdpDiscoveryEndpoint 

func (x *OAuth2TokenRequest) GetIdpDiscoveryEndpoint() string

func (*OAuth2TokenRequest) GetName 

func (x *OAuth2TokenRequest) GetName() string

func (*OAuth2TokenRequest) GetTokenEndpoint 

func (x *OAuth2TokenRequest) GetTokenEndpoint() string

func (*OAuth2TokenRequest) GetType 

func (x *OAuth2TokenRequest) GetType() OAuth2TokenRequest_Type

func (*OAuth2TokenRequest) ProtoMessage 

func (*OAuth2TokenRequest) ProtoMessage()

func (*OAuth2TokenRequest) ProtoReflect added in v1.10.7 

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

func (*OAuth2TokenRequest) Reset 

func (x *OAuth2TokenRequest) Reset()

func (*OAuth2TokenRequest) String 

func (x *OAuth2TokenRequest) String() string

type OAuth2TokenRequest_Type 

type OAuth2TokenRequest_Type int32

Type of the token requested. 

const (
	// CLIENT_CREDENTIALS indicates a 2-legged OAuth token requested using client credentials.
	OAuth2TokenRequest_CLIENT_CREDENTIALS OAuth2TokenRequest_Type = 0
)

func (OAuth2TokenRequest_Type) Descriptor added in v1.10.7 

func (OAuth2TokenRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (OAuth2TokenRequest_Type) Enum added in v1.10.7 

func (x OAuth2TokenRequest_Type) Enum() *OAuth2TokenRequest_Type

func (OAuth2TokenRequest_Type) EnumDescriptor deprecated 

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

Deprecated: Use OAuth2TokenRequest_Type.Descriptor instead.

func (OAuth2TokenRequest_Type) Number added in v1.10.7 

func (x OAuth2TokenRequest_Type) Number() protoreflect.EnumNumber

func (OAuth2TokenRequest_Type) String 

func (x OAuth2TokenRequest_Type) String() string

func (OAuth2TokenRequest_Type) Type added in v1.10.7 

func (OAuth2TokenRequest_Type) Type() protoreflect.EnumType

type Operand 

type Operand struct {

	// Types that are assignable to Val:
	//
	//	*Operand_Primitive
	//	*Operand_Var
	//	*Operand_Scalar
	Val isOperand_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

Defines an operand to a comparison expression.

func (*Operand) Descriptor deprecated 

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

Deprecated: Use Operand.ProtoReflect.Descriptor instead.

func (*Operand) GetPrimitive deprecated 

func (x *Operand) GetPrimitive() *Primitive

Deprecated: Marked as deprecated in flyteidl/core/condition.proto.

func (*Operand) GetScalar 

func (x *Operand) GetScalar() *Scalar

func (*Operand) GetVal 

func (m *Operand) GetVal() isOperand_Val

func (*Operand) GetVar 

func (x *Operand) GetVar() string

func (*Operand) ProtoMessage 

func (*Operand) ProtoMessage()

func (*Operand) ProtoReflect added in v1.10.7 

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

func (*Operand) Reset 

func (x *Operand) Reset()

func (*Operand) String 

func (x *Operand) String() string

type Operand_Primitive 

type Operand_Primitive struct {
	// Can be a constant
	//
	// Deprecated: Marked as deprecated in flyteidl/core/condition.proto.
	Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

type Operand_Scalar 

type Operand_Scalar struct {
	// Replace the primitive field
	Scalar *Scalar `protobuf:"bytes,3,opt,name=scalar,proto3,oneof"`
}

type Operand_Var 

type Operand_Var struct {
	// Or one of this node's input variables
	Var string `protobuf:"bytes,2,opt,name=var,proto3,oneof"`
}

type Operator added in v1.11.0 

type Operator int32
const (
	Operator_MINUS Operator = 0
	Operator_PLUS  Operator = 1
)

func (Operator) Descriptor added in v1.11.0 

func (Operator) Descriptor() protoreflect.EnumDescriptor

func (Operator) Enum added in v1.11.0 

func (x Operator) Enum() *Operator

func (Operator) EnumDescriptor deprecated added in v1.11.0 

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

Deprecated: Use Operator.Descriptor instead.

func (Operator) Number added in v1.11.0 

func (x Operator) Number() protoreflect.EnumNumber

func (Operator) String added in v1.11.0 

func (x Operator) String() string

func (Operator) Type added in v1.11.0 

func (Operator) Type() protoreflect.EnumType

type OutputReference 

type OutputReference struct {

	// Node id must exist at the graph layer.
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// Variable name must refer to an output variable for the node.
	Var      string              `protobuf:"bytes,2,opt,name=var,proto3" json:"var,omitempty"`
	AttrPath []*PromiseAttribute `protobuf:"bytes,3,rep,name=attr_path,json=attrPath,proto3" json:"attr_path,omitempty"`
	// contains filtered or unexported fields
}

A reference to an output produced by a node. The type can be retrieved -and validated- from the underlying interface of the node.

func (*OutputReference) Descriptor deprecated 

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

Deprecated: Use OutputReference.ProtoReflect.Descriptor instead.

func (*OutputReference) GetAttrPath 

func (x *OutputReference) GetAttrPath() []*PromiseAttribute

func (*OutputReference) GetNodeId 

func (x *OutputReference) GetNodeId() string

func (*OutputReference) GetVar 

func (x *OutputReference) GetVar() string

func (*OutputReference) ProtoMessage 

func (*OutputReference) ProtoMessage()

func (*OutputReference) ProtoReflect added in v1.10.7 

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

func (*OutputReference) Reset 

func (x *OutputReference) Reset()

func (*OutputReference) String 

func (x *OutputReference) String() string

type Parameter 

type Parameter struct {

	// +required Variable. Defines the type of the variable backing this parameter.
	Var *Variable `protobuf:"bytes,1,opt,name=var,proto3" json:"var,omitempty"`
	// +optional
	//
	// Types that are assignable to Behavior:
	//
	//	*Parameter_Default
	//	*Parameter_Required
	//	*Parameter_ArtifactQuery
	//	*Parameter_ArtifactId
	Behavior isParameter_Behavior `protobuf_oneof:"behavior"`
	// contains filtered or unexported fields
}

A parameter is used as input to a launch plan and has the special ability to have a default value or mark itself as required.

func (*Parameter) Descriptor deprecated 

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

Deprecated: Use Parameter.ProtoReflect.Descriptor instead.

func (*Parameter) GetArtifactId added in v1.10.7 

func (x *Parameter) GetArtifactId() *ArtifactID

func (*Parameter) GetArtifactQuery added in v1.10.7 

func (x *Parameter) GetArtifactQuery() *ArtifactQuery

func (*Parameter) GetBehavior 

func (m *Parameter) GetBehavior() isParameter_Behavior

func (*Parameter) GetDefault 

func (x *Parameter) GetDefault() *Literal

func (*Parameter) GetRequired 

func (x *Parameter) GetRequired() bool

func (*Parameter) GetVar 

func (x *Parameter) GetVar() *Variable

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) ProtoReflect added in v1.10.7 

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

func (*Parameter) Reset 

func (x *Parameter) Reset()

func (*Parameter) String 

func (x *Parameter) String() string

type ParameterMap 

type ParameterMap struct {

	// Defines a map of parameter names to parameters.
	Parameters map[string]*Parameter `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

A map of Parameters.

func (*ParameterMap) Descriptor deprecated 

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

Deprecated: Use ParameterMap.ProtoReflect.Descriptor instead.

func (*ParameterMap) GetParameters 

func (x *ParameterMap) GetParameters() map[string]*Parameter

func (*ParameterMap) ProtoMessage 

func (*ParameterMap) ProtoMessage()

func (*ParameterMap) ProtoReflect added in v1.10.7 

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

func (*ParameterMap) Reset 

func (x *ParameterMap) Reset()

func (*ParameterMap) String 

func (x *ParameterMap) String() string

type Parameter_ArtifactId added in v1.10.7 

type Parameter_ArtifactId struct {
	ArtifactId *ArtifactID `protobuf:"bytes,5,opt,name=artifact_id,json=artifactId,proto3,oneof"`
}

type Parameter_ArtifactQuery added in v1.10.7 

type Parameter_ArtifactQuery struct {
	// This is an execution time search basically that should result in exactly one Artifact with a Type that
	// matches the type of the variable.
	ArtifactQuery *ArtifactQuery `protobuf:"bytes,4,opt,name=artifact_query,json=artifactQuery,proto3,oneof"`
}

type Parameter_Default 

type Parameter_Default struct {
	// Defines a default value that has to match the variable type defined.
	Default *Literal `protobuf:"bytes,2,opt,name=default,proto3,oneof"`
}

type Parameter_Required 

type Parameter_Required struct {
	// +optional, is this value required to be filled.
	Required bool `protobuf:"varint,3,opt,name=required,proto3,oneof"`
}

type Partitions added in v1.10.7 

type Partitions struct {
	Value map[string]*LabelValue `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

Deprecated: Use Partitions.ProtoReflect.Descriptor instead.

func (*Partitions) GetValue added in v1.10.7 

func (x *Partitions) GetValue() map[string]*LabelValue

func (*Partitions) ProtoMessage added in v1.10.7 

func (*Partitions) ProtoMessage()

func (*Partitions) ProtoReflect added in v1.10.7 

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

func (*Partitions) Reset added in v1.10.7 

func (x *Partitions) Reset()

func (*Partitions) String added in v1.10.7 

func (x *Partitions) String() string

type Primitive 

type Primitive struct {

	// Defines one of simple primitive types. These types will get translated into different programming languages as
	// described in https://developers.google.com/protocol-buffers/docs/proto#scalar.
	//
	// Types that are assignable to Value:
	//
	//	*Primitive_Integer
	//	*Primitive_FloatValue
	//	*Primitive_StringValue
	//	*Primitive_Boolean
	//	*Primitive_Datetime
	//	*Primitive_Duration
	Value isPrimitive_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Primitive Types

func (*Primitive) Descriptor deprecated 

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

Deprecated: Use Primitive.ProtoReflect.Descriptor instead.

func (*Primitive) GetBoolean 

func (x *Primitive) GetBoolean() bool

func (*Primitive) GetDatetime 

func (x *Primitive) GetDatetime() *timestamppb.Timestamp

func (*Primitive) GetDuration 

func (x *Primitive) GetDuration() *durationpb.Duration

func (*Primitive) GetFloatValue 

func (x *Primitive) GetFloatValue() float64

func (*Primitive) GetInteger 

func (x *Primitive) GetInteger() int64

func (*Primitive) GetStringValue 

func (x *Primitive) GetStringValue() string

func (*Primitive) GetValue 

func (m *Primitive) GetValue() isPrimitive_Value

func (*Primitive) ProtoMessage 

func (*Primitive) ProtoMessage()

func (*Primitive) ProtoReflect added in v1.10.7 

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

func (*Primitive) Reset 

func (x *Primitive) Reset()

func (*Primitive) String 

func (x *Primitive) String() string

type Primitive_Boolean 

type Primitive_Boolean struct {
	Boolean bool `protobuf:"varint,4,opt,name=boolean,proto3,oneof"`
}

type Primitive_Datetime 

type Primitive_Datetime struct {
	Datetime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=datetime,proto3,oneof"`
}

type Primitive_Duration 

type Primitive_Duration struct {
	Duration *durationpb.Duration `protobuf:"bytes,6,opt,name=duration,proto3,oneof"`
}

type Primitive_FloatValue 

type Primitive_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,2,opt,name=float_value,json=floatValue,proto3,oneof"`
}

type Primitive_Integer 

type Primitive_Integer struct {
	Integer int64 `protobuf:"varint,1,opt,name=integer,proto3,oneof"`
}

type Primitive_StringValue 

type Primitive_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type PromiseAttribute 

type PromiseAttribute struct {

	// Types that are assignable to Value:
	//
	//	*PromiseAttribute_StringValue
	//	*PromiseAttribute_IntValue
	Value isPromiseAttribute_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*PromiseAttribute) Descriptor deprecated 

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

Deprecated: Use PromiseAttribute.ProtoReflect.Descriptor instead.

func (*PromiseAttribute) GetIntValue 

func (x *PromiseAttribute) GetIntValue() int32

func (*PromiseAttribute) GetStringValue 

func (x *PromiseAttribute) GetStringValue() string

func (*PromiseAttribute) GetValue 

func (m *PromiseAttribute) GetValue() isPromiseAttribute_Value

func (*PromiseAttribute) ProtoMessage 

func (*PromiseAttribute) ProtoMessage()

func (*PromiseAttribute) ProtoReflect added in v1.10.7 

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

func (*PromiseAttribute) Reset 

func (x *PromiseAttribute) Reset()

func (*PromiseAttribute) String 

func (x *PromiseAttribute) String() string

type PromiseAttribute_IntValue 

type PromiseAttribute_IntValue struct {
	IntValue int32 `protobuf:"varint,2,opt,name=int_value,json=intValue,proto3,oneof"`
}

type PromiseAttribute_StringValue 

type PromiseAttribute_StringValue struct {
	StringValue string `protobuf:"bytes,1,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type QualityOfService 

type QualityOfService struct {

	// Types that are assignable to Designation:
	//
	//	*QualityOfService_Tier_
	//	*QualityOfService_Spec
	Designation isQualityOfService_Designation `protobuf_oneof:"designation"`
	// contains filtered or unexported fields
}

Indicates the priority of an execution.

func (*QualityOfService) Descriptor deprecated 

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

Deprecated: Use QualityOfService.ProtoReflect.Descriptor instead.

func (*QualityOfService) GetDesignation 

func (m *QualityOfService) GetDesignation() isQualityOfService_Designation

func (*QualityOfService) GetSpec 

func (x *QualityOfService) GetSpec() *QualityOfServiceSpec

func (*QualityOfService) GetTier 

func (x *QualityOfService) GetTier() QualityOfService_Tier

func (*QualityOfService) ProtoMessage 

func (*QualityOfService) ProtoMessage()

func (*QualityOfService) ProtoReflect added in v1.10.7 

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

func (*QualityOfService) Reset 

func (x *QualityOfService) Reset()

func (*QualityOfService) String 

func (x *QualityOfService) String() string

type QualityOfServiceSpec 

type QualityOfServiceSpec struct {

	// Indicates how much queueing delay an execution can tolerate.
	QueueingBudget *durationpb.Duration `protobuf:"bytes,1,opt,name=queueing_budget,json=queueingBudget,proto3" json:"queueing_budget,omitempty"`
	// contains filtered or unexported fields
}

Represents customized execution run-time attributes.

func (*QualityOfServiceSpec) Descriptor deprecated 

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

Deprecated: Use QualityOfServiceSpec.ProtoReflect.Descriptor instead.

func (*QualityOfServiceSpec) GetQueueingBudget 

func (x *QualityOfServiceSpec) GetQueueingBudget() *durationpb.Duration

func (*QualityOfServiceSpec) ProtoMessage 

func (*QualityOfServiceSpec) ProtoMessage()

func (*QualityOfServiceSpec) ProtoReflect added in v1.10.7 

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

func (*QualityOfServiceSpec) Reset 

func (x *QualityOfServiceSpec) Reset()

func (*QualityOfServiceSpec) String 

func (x *QualityOfServiceSpec) String() string

type QualityOfService_Spec 

type QualityOfService_Spec struct {
	Spec *QualityOfServiceSpec `protobuf:"bytes,2,opt,name=spec,proto3,oneof"`
}

type QualityOfService_Tier 

type QualityOfService_Tier int32
const (
	// Default: no quality of service specified.
	QualityOfService_UNDEFINED QualityOfService_Tier = 0
	QualityOfService_HIGH      QualityOfService_Tier = 1
	QualityOfService_MEDIUM    QualityOfService_Tier = 2
	QualityOfService_LOW       QualityOfService_Tier = 3
)

func (QualityOfService_Tier) Descriptor added in v1.10.7 

func (QualityOfService_Tier) Descriptor() protoreflect.EnumDescriptor

func (QualityOfService_Tier) Enum added in v1.10.7 

func (x QualityOfService_Tier) Enum() *QualityOfService_Tier

func (QualityOfService_Tier) EnumDescriptor deprecated 

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

Deprecated: Use QualityOfService_Tier.Descriptor instead.

func (QualityOfService_Tier) Number added in v1.10.7 

func (x QualityOfService_Tier) Number() protoreflect.EnumNumber

func (QualityOfService_Tier) String 

func (x QualityOfService_Tier) String() string

func (QualityOfService_Tier) Type added in v1.10.7 

func (QualityOfService_Tier) Type() protoreflect.EnumType

type QualityOfService_Tier_ 

type QualityOfService_Tier_ struct {
	Tier QualityOfService_Tier `protobuf:"varint,1,opt,name=tier,proto3,enum=flyteidl.core.QualityOfService_Tier,oneof"`
}

type ResourceType 

type ResourceType int32

Indicates a resource type within Flyte. 

const (
	ResourceType_UNSPECIFIED ResourceType = 0
	ResourceType_TASK        ResourceType = 1
	ResourceType_WORKFLOW    ResourceType = 2
	ResourceType_LAUNCH_PLAN ResourceType = 3
	// A dataset represents an entity modeled in Flyte DataCatalog. A Dataset is also a versioned entity and can be a compilation of multiple individual objects.
	// Eventually all Catalog objects should be modeled similar to Flyte Objects. The Dataset entities makes it possible for the UI  and CLI to act on the objects
	// in a similar manner to other Flyte objects
	ResourceType_DATASET ResourceType = 4
)

func (ResourceType) Descriptor added in v1.10.7 

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum added in v1.10.7 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number added in v1.10.7 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String 

func (x ResourceType) String() string

func (ResourceType) Type added in v1.10.7 

func (ResourceType) Type() protoreflect.EnumType

type Resources 

type Resources struct {

	// The desired set of resources requested. ResourceNames must be unique within the list.
	Requests []*Resources_ResourceEntry `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// Defines a set of bounds (e.g. min/max) within which the task can reliably run. ResourceNames must be unique
	// within the list.
	Limits []*Resources_ResourceEntry `protobuf:"bytes,2,rep,name=limits,proto3" json:"limits,omitempty"`
	// contains filtered or unexported fields
}

A customizable interface to convey resources requested for a container. This can be interpreted differently for different container engines.

func (*Resources) Descriptor deprecated 

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

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetLimits 

func (x *Resources) GetLimits() []*Resources_ResourceEntry

func (*Resources) GetRequests 

func (x *Resources) GetRequests() []*Resources_ResourceEntry

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect added in v1.10.7 

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

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) String 

func (x *Resources) String() string

type Resources_ResourceEntry 

type Resources_ResourceEntry struct {

	// Resource name.
	Name Resources_ResourceName `protobuf:"varint,1,opt,name=name,proto3,enum=flyteidl.core.Resources_ResourceName" json:"name,omitempty"`
	// Value must be a valid k8s quantity. See
	// https://github.com/kubernetes/apimachinery/blob/master/pkg/api/resource/quantity.go#L30-L80
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Encapsulates a resource name and value.

func (*Resources_ResourceEntry) Descriptor deprecated 

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

Deprecated: Use Resources_ResourceEntry.ProtoReflect.Descriptor instead.

func (*Resources_ResourceEntry) GetName 

func (x *Resources_ResourceEntry) GetName() Resources_ResourceName

func (*Resources_ResourceEntry) GetValue 

func (x *Resources_ResourceEntry) GetValue() string

func (*Resources_ResourceEntry) ProtoMessage 

func (*Resources_ResourceEntry) ProtoMessage()

func (*Resources_ResourceEntry) ProtoReflect added in v1.10.7 

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

func (*Resources_ResourceEntry) Reset 

func (x *Resources_ResourceEntry) Reset()

func (*Resources_ResourceEntry) String 

func (x *Resources_ResourceEntry) String() string

type Resources_ResourceName 

type Resources_ResourceName int32

Known resource names. 

const (
	Resources_UNKNOWN Resources_ResourceName = 0
	Resources_CPU     Resources_ResourceName = 1
	Resources_GPU     Resources_ResourceName = 2
	Resources_MEMORY  Resources_ResourceName = 3
	Resources_STORAGE Resources_ResourceName = 4
	// For Kubernetes-based deployments, pods use ephemeral local storage for scratch space, caching, and for logs.
	Resources_EPHEMERAL_STORAGE Resources_ResourceName = 5
)

func (Resources_ResourceName) Descriptor added in v1.10.7 

func (Resources_ResourceName) Descriptor() protoreflect.EnumDescriptor

func (Resources_ResourceName) Enum added in v1.10.7 

func (x Resources_ResourceName) Enum() *Resources_ResourceName

func (Resources_ResourceName) EnumDescriptor deprecated 

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

Deprecated: Use Resources_ResourceName.Descriptor instead.

func (Resources_ResourceName) Number added in v1.10.7 

func (x Resources_ResourceName) Number() protoreflect.EnumNumber

func (Resources_ResourceName) String 

func (x Resources_ResourceName) String() string

func (Resources_ResourceName) Type added in v1.10.7 

func (Resources_ResourceName) Type() protoreflect.EnumType

type RetryStrategy 

type RetryStrategy struct {

	// Number of retries. Retries will be consumed when the job fails with a recoverable error.
	// The number of retries must be less than or equals to 10.
	Retries uint32 `protobuf:"varint,5,opt,name=retries,proto3" json:"retries,omitempty"`
	// contains filtered or unexported fields
}

Retry strategy associated with an executable unit.

func (*RetryStrategy) Descriptor deprecated 

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

Deprecated: Use RetryStrategy.ProtoReflect.Descriptor instead.

func (*RetryStrategy) GetRetries 

func (x *RetryStrategy) GetRetries() uint32

func (*RetryStrategy) ProtoMessage 

func (*RetryStrategy) ProtoMessage()

func (*RetryStrategy) ProtoReflect added in v1.10.7 

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

func (*RetryStrategy) Reset 

func (x *RetryStrategy) Reset()

func (*RetryStrategy) String 

func (x *RetryStrategy) String() string

type RuntimeBinding added in v1.11.0 

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

func (*RuntimeBinding) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use RuntimeBinding.ProtoReflect.Descriptor instead.

func (*RuntimeBinding) ProtoMessage added in v1.11.0 

func (*RuntimeBinding) ProtoMessage()

func (*RuntimeBinding) ProtoReflect added in v1.11.0 

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

func (*RuntimeBinding) Reset added in v1.11.0 

func (x *RuntimeBinding) Reset()

func (*RuntimeBinding) String added in v1.11.0 

func (x *RuntimeBinding) String() string

type RuntimeMetadata 

type RuntimeMetadata struct {

	// Type of runtime.
	Type RuntimeMetadata_RuntimeType `protobuf:"varint,1,opt,name=type,proto3,enum=flyteidl.core.RuntimeMetadata_RuntimeType" json:"type,omitempty"`
	// Version of the runtime. All versions should be backward compatible. However, certain cases call for version
	// checks to ensure tighter validation or setting expectations.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// +optional It can be used to provide extra information about the runtime (e.g. python, golang... etc.).
	Flavor string `protobuf:"bytes,3,opt,name=flavor,proto3" json:"flavor,omitempty"`
	// contains filtered or unexported fields
}

Runtime information. This is loosely defined to allow for extensibility.

func (*RuntimeMetadata) Descriptor deprecated 

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

Deprecated: Use RuntimeMetadata.ProtoReflect.Descriptor instead.

func (*RuntimeMetadata) GetFlavor 

func (x *RuntimeMetadata) GetFlavor() string

func (*RuntimeMetadata) GetType 

func (x *RuntimeMetadata) GetType() RuntimeMetadata_RuntimeType

func (*RuntimeMetadata) GetVersion 

func (x *RuntimeMetadata) GetVersion() string

func (*RuntimeMetadata) ProtoMessage 

func (*RuntimeMetadata) ProtoMessage()

func (*RuntimeMetadata) ProtoReflect added in v1.10.7 

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

func (*RuntimeMetadata) Reset 

func (x *RuntimeMetadata) Reset()

func (*RuntimeMetadata) String 

func (x *RuntimeMetadata) String() string

type RuntimeMetadata_RuntimeType 

type RuntimeMetadata_RuntimeType int32
const (
	RuntimeMetadata_OTHER     RuntimeMetadata_RuntimeType = 0
	RuntimeMetadata_FLYTE_SDK RuntimeMetadata_RuntimeType = 1
)

func (RuntimeMetadata_RuntimeType) Descriptor added in v1.10.7 

func (RuntimeMetadata_RuntimeType) Descriptor() protoreflect.EnumDescriptor

func (RuntimeMetadata_RuntimeType) Enum added in v1.10.7 

func (x RuntimeMetadata_RuntimeType) Enum() *RuntimeMetadata_RuntimeType

func (RuntimeMetadata_RuntimeType) EnumDescriptor deprecated 

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

Deprecated: Use RuntimeMetadata_RuntimeType.Descriptor instead.

func (RuntimeMetadata_RuntimeType) Number added in v1.10.7 

func (x RuntimeMetadata_RuntimeType) Number() protoreflect.EnumNumber

func (RuntimeMetadata_RuntimeType) String 

func (x RuntimeMetadata_RuntimeType) String() string

func (RuntimeMetadata_RuntimeType) Type added in v1.10.7 

func (RuntimeMetadata_RuntimeType) Type() protoreflect.EnumType

type Scalar 

type Scalar struct {

	// Types that are assignable to Value:
	//
	//	*Scalar_Primitive
	//	*Scalar_Blob
	//	*Scalar_Binary
	//	*Scalar_Schema
	//	*Scalar_NoneType
	//	*Scalar_Error
	//	*Scalar_Generic
	//	*Scalar_StructuredDataset
	//	*Scalar_Union
	Value isScalar_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Scalar) Descriptor deprecated 

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

Deprecated: Use Scalar.ProtoReflect.Descriptor instead.

func (*Scalar) GetBinary 

func (x *Scalar) GetBinary() *Binary

func (*Scalar) GetBlob 

func (x *Scalar) GetBlob() *Blob

func (*Scalar) GetError 

func (x *Scalar) GetError() *Error

func (*Scalar) GetGeneric 

func (x *Scalar) GetGeneric() *structpb.Struct

func (*Scalar) GetNoneType 

func (x *Scalar) GetNoneType() *Void

func (*Scalar) GetPrimitive 

func (x *Scalar) GetPrimitive() *Primitive

func (*Scalar) GetSchema 

func (x *Scalar) GetSchema() *Schema

func (*Scalar) GetStructuredDataset 

func (x *Scalar) GetStructuredDataset() *StructuredDataset

func (*Scalar) GetUnion 

func (x *Scalar) GetUnion() *Union

func (*Scalar) GetValue 

func (m *Scalar) GetValue() isScalar_Value

func (*Scalar) ProtoMessage 

func (*Scalar) ProtoMessage()

func (*Scalar) ProtoReflect added in v1.10.7 

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

func (*Scalar) Reset 

func (x *Scalar) Reset()

func (*Scalar) String 

func (x *Scalar) String() string

type Scalar_Binary 

type Scalar_Binary struct {
	Binary *Binary `protobuf:"bytes,3,opt,name=binary,proto3,oneof"`
}

type Scalar_Blob 

type Scalar_Blob struct {
	Blob *Blob `protobuf:"bytes,2,opt,name=blob,proto3,oneof"`
}

type Scalar_Error 

type Scalar_Error struct {
	Error *Error `protobuf:"bytes,6,opt,name=error,proto3,oneof"`
}

type Scalar_Generic 

type Scalar_Generic struct {
	Generic *structpb.Struct `protobuf:"bytes,7,opt,name=generic,proto3,oneof"`
}

type Scalar_NoneType 

type Scalar_NoneType struct {
	NoneType *Void `protobuf:"bytes,5,opt,name=none_type,json=noneType,proto3,oneof"`
}

type Scalar_Primitive 

type Scalar_Primitive struct {
	Primitive *Primitive `protobuf:"bytes,1,opt,name=primitive,proto3,oneof"`
}

type Scalar_Schema 

type Scalar_Schema struct {
	Schema *Schema `protobuf:"bytes,4,opt,name=schema,proto3,oneof"`
}

type Scalar_StructuredDataset 

type Scalar_StructuredDataset struct {
	StructuredDataset *StructuredDataset `protobuf:"bytes,8,opt,name=structured_dataset,json=structuredDataset,proto3,oneof"`
}

type Scalar_Union 

type Scalar_Union struct {
	Union *Union `protobuf:"bytes,9,opt,name=union,proto3,oneof"`
}

type Schema 

type Schema struct {
	Uri  string      `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Type *SchemaType `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

A strongly typed schema that defines the interface of data retrieved from the underlying storage medium.

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetType 

func (x *Schema) GetType() *SchemaType

func (*Schema) GetUri 

func (x *Schema) GetUri() string

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect added in v1.10.7 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type SchemaType 

type SchemaType struct {

	// A list of ordered columns this schema comprises of.
	Columns []*SchemaType_SchemaColumn `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

Defines schema columns and types to strongly type-validate schemas interoperability.

func (*SchemaType) Descriptor deprecated 

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

Deprecated: Use SchemaType.ProtoReflect.Descriptor instead.

func (*SchemaType) GetColumns 

func (x *SchemaType) GetColumns() []*SchemaType_SchemaColumn

func (*SchemaType) ProtoMessage 

func (*SchemaType) ProtoMessage()

func (*SchemaType) ProtoReflect added in v1.10.7 

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

func (*SchemaType) Reset 

func (x *SchemaType) Reset()

func (*SchemaType) String 

func (x *SchemaType) String() string

type SchemaType_SchemaColumn 

type SchemaType_SchemaColumn struct {

	// A unique name -within the schema type- for the column
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The column type. This allows a limited set of types currently.
	Type SchemaType_SchemaColumn_SchemaColumnType `protobuf:"varint,2,opt,name=type,proto3,enum=flyteidl.core.SchemaType_SchemaColumn_SchemaColumnType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaType_SchemaColumn) Descriptor deprecated 

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

Deprecated: Use SchemaType_SchemaColumn.ProtoReflect.Descriptor instead.

func (*SchemaType_SchemaColumn) GetName 

func (x *SchemaType_SchemaColumn) GetName() string

func (*SchemaType_SchemaColumn) GetType 

func (x *SchemaType_SchemaColumn) GetType() SchemaType_SchemaColumn_SchemaColumnType

func (*SchemaType_SchemaColumn) ProtoMessage 

func (*SchemaType_SchemaColumn) ProtoMessage()

func (*SchemaType_SchemaColumn) ProtoReflect added in v1.10.7 

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

func (*SchemaType_SchemaColumn) Reset 

func (x *SchemaType_SchemaColumn) Reset()

func (*SchemaType_SchemaColumn) String 

func (x *SchemaType_SchemaColumn) String() string

type SchemaType_SchemaColumn_SchemaColumnType 

type SchemaType_SchemaColumn_SchemaColumnType int32
const (
	SchemaType_SchemaColumn_INTEGER  SchemaType_SchemaColumn_SchemaColumnType = 0
	SchemaType_SchemaColumn_FLOAT    SchemaType_SchemaColumn_SchemaColumnType = 1
	SchemaType_SchemaColumn_STRING   SchemaType_SchemaColumn_SchemaColumnType = 2
	SchemaType_SchemaColumn_BOOLEAN  SchemaType_SchemaColumn_SchemaColumnType = 3
	SchemaType_SchemaColumn_DATETIME SchemaType_SchemaColumn_SchemaColumnType = 4
	SchemaType_SchemaColumn_DURATION SchemaType_SchemaColumn_SchemaColumnType = 5
)

func (SchemaType_SchemaColumn_SchemaColumnType) Descriptor added in v1.10.7 

func (SchemaType_SchemaColumn_SchemaColumnType) Descriptor() protoreflect.EnumDescriptor

func (SchemaType_SchemaColumn_SchemaColumnType) Enum added in v1.10.7 

func (x SchemaType_SchemaColumn_SchemaColumnType) Enum() *SchemaType_SchemaColumn_SchemaColumnType

func (SchemaType_SchemaColumn_SchemaColumnType) EnumDescriptor deprecated 

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

Deprecated: Use SchemaType_SchemaColumn_SchemaColumnType.Descriptor instead.

func (SchemaType_SchemaColumn_SchemaColumnType) Number added in v1.10.7 

func (x SchemaType_SchemaColumn_SchemaColumnType) Number() protoreflect.EnumNumber

func (SchemaType_SchemaColumn_SchemaColumnType) String 

func (x SchemaType_SchemaColumn_SchemaColumnType) String() string

func (SchemaType_SchemaColumn_SchemaColumnType) Type added in v1.10.7 

func (SchemaType_SchemaColumn_SchemaColumnType) Type() protoreflect.EnumType

type Secret 

type Secret struct {

	// The name of the secret group where to find the key referenced below. For K8s secrets, this should be the name of
	// the v1/secret object. For Confidant, this should be the Credential name. For Vault, this should be the secret name.
	// For AWS Secret Manager, this should be the name of the secret.
	// +required
	Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// The group version to fetch. This is not supported in all secret management systems. It'll be ignored for the ones
	// that do not support it.
	// +optional
	GroupVersion string `protobuf:"bytes,2,opt,name=group_version,json=groupVersion,proto3" json:"group_version,omitempty"`
	// The name of the secret to mount. This has to match an existing secret in the system. It's up to the implementation
	// of the secret management system to require case sensitivity. For K8s secrets, Confidant and Vault, this should
	// match one of the keys inside the secret. For AWS Secret Manager, it's ignored.
	// +optional
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// mount_requirement is optional. Indicates where the secret has to be mounted. If provided, the execution will fail
	// if the underlying key management system cannot satisfy that requirement. If not provided, the default location
	// will depend on the key management system.
	// +optional
	MountRequirement Secret_MountType `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

Secret encapsulates information about the secret a task needs to proceed. An environment variable FLYTE_SECRETS_ENV_PREFIX will be passed to indicate the prefix of the environment variables that will be present if secrets are passed through environment variables. FLYTE_SECRETS_DEFAULT_DIR will be passed to indicate the prefix of the path where secrets will be mounted if secrets are passed through file mounts.

func (*Secret) Descriptor deprecated 

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetGroup 

func (x *Secret) GetGroup() string

func (*Secret) GetGroupVersion 

func (x *Secret) GetGroupVersion() string

func (*Secret) GetKey 

func (x *Secret) GetKey() string

func (*Secret) GetMountRequirement 

func (x *Secret) GetMountRequirement() Secret_MountType

func (*Secret) ProtoMessage 

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect added in v1.10.7 

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

func (*Secret) Reset 

func (x *Secret) Reset()

func (*Secret) String 

func (x *Secret) String() string

type Secret_MountType 

type Secret_MountType int32
const (
	// Default case, indicates the client can tolerate either mounting options.
	Secret_ANY Secret_MountType = 0
	// ENV_VAR indicates the secret needs to be mounted as an environment variable.
	Secret_ENV_VAR Secret_MountType = 1
	// FILE indicates the secret needs to be mounted as a file.
	Secret_FILE Secret_MountType = 2
)

func (Secret_MountType) Descriptor added in v1.10.7 

func (Secret_MountType) Descriptor() protoreflect.EnumDescriptor

func (Secret_MountType) Enum added in v1.10.7 

func (x Secret_MountType) Enum() *Secret_MountType

func (Secret_MountType) EnumDescriptor deprecated 

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

Deprecated: Use Secret_MountType.Descriptor instead.

func (Secret_MountType) Number added in v1.10.7 

func (x Secret_MountType) Number() protoreflect.EnumNumber

func (Secret_MountType) String 

func (x Secret_MountType) String() string

func (Secret_MountType) Type added in v1.10.7 

func (Secret_MountType) Type() protoreflect.EnumType

type SecurityContext 

type SecurityContext struct {

	// run_as encapsulates the identity a pod should run as. If the task fills in multiple fields here, it'll be up to the
	// backend plugin to choose the appropriate identity for the execution engine the task will run on.
	RunAs *Identity `protobuf:"bytes,1,opt,name=run_as,json=runAs,proto3" json:"run_as,omitempty"`
	// secrets indicate the list of secrets the task needs in order to proceed. Secrets will be mounted/passed to the
	// pod as it starts. If the plugin responsible for kicking of the task will not run it on a flyte cluster (e.g. AWS
	// Batch), it's the responsibility of the plugin to fetch the secret (which means propeller identity will need access
	// to the secret) and to pass it to the remote execution engine.
	Secrets []*Secret `protobuf:"bytes,2,rep,name=secrets,proto3" json:"secrets,omitempty"`
	// tokens indicate the list of token requests the task needs in order to proceed. Tokens will be mounted/passed to the
	// pod as it starts. If the plugin responsible for kicking of the task will not run it on a flyte cluster (e.g. AWS
	// Batch), it's the responsibility of the plugin to fetch the secret (which means propeller identity will need access
	// to the secret) and to pass it to the remote execution engine.
	Tokens []*OAuth2TokenRequest `protobuf:"bytes,3,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

SecurityContext holds security attributes that apply to tasks.

func (*SecurityContext) Descriptor deprecated 

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

Deprecated: Use SecurityContext.ProtoReflect.Descriptor instead.

func (*SecurityContext) GetRunAs 

func (x *SecurityContext) GetRunAs() *Identity

func (*SecurityContext) GetSecrets 

func (x *SecurityContext) GetSecrets() []*Secret

func (*SecurityContext) GetTokens 

func (x *SecurityContext) GetTokens() []*OAuth2TokenRequest

func (*SecurityContext) ProtoMessage 

func (*SecurityContext) ProtoMessage()

func (*SecurityContext) ProtoReflect added in v1.10.7 

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

func (*SecurityContext) Reset 

func (x *SecurityContext) Reset()

func (*SecurityContext) String 

func (x *SecurityContext) String() string

type SignalCondition 

type SignalCondition struct {

	// A unique identifier for the requested signal.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// A type denoting the required value type for this signal.
	Type *LiteralType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// The variable name for the signal value in this nodes outputs.
	OutputVariableName string `protobuf:"bytes,3,opt,name=output_variable_name,json=outputVariableName,proto3" json:"output_variable_name,omitempty"`
	// contains filtered or unexported fields
}

SignalCondition represents a dependency on an signal.

func (*SignalCondition) Descriptor deprecated 

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

Deprecated: Use SignalCondition.ProtoReflect.Descriptor instead.

func (*SignalCondition) GetOutputVariableName 

func (x *SignalCondition) GetOutputVariableName() string

func (*SignalCondition) GetSignalId 

func (x *SignalCondition) GetSignalId() string

func (*SignalCondition) GetType 

func (x *SignalCondition) GetType() *LiteralType

func (*SignalCondition) ProtoMessage 

func (*SignalCondition) ProtoMessage()

func (*SignalCondition) ProtoReflect added in v1.10.7 

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

func (*SignalCondition) Reset 

func (x *SignalCondition) Reset()

func (*SignalCondition) String 

func (x *SignalCondition) String() string

type SignalIdentifier 

type SignalIdentifier struct {

	// Unique identifier for a signal.
	SignalId string `protobuf:"bytes,1,opt,name=signal_id,json=signalId,proto3" json:"signal_id,omitempty"`
	// Identifies the Flyte workflow execution this signal belongs to.
	ExecutionId *WorkflowExecutionIdentifier `protobuf:"bytes,2,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

Encapsulation of fields the uniquely identify a signal.

func (*SignalIdentifier) Descriptor deprecated 

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

Deprecated: Use SignalIdentifier.ProtoReflect.Descriptor instead.

func (*SignalIdentifier) GetExecutionId 

func (x *SignalIdentifier) GetExecutionId() *WorkflowExecutionIdentifier

func (*SignalIdentifier) GetSignalId 

func (x *SignalIdentifier) GetSignalId() string

func (*SignalIdentifier) ProtoMessage 

func (*SignalIdentifier) ProtoMessage()

func (*SignalIdentifier) ProtoReflect added in v1.10.7 

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

func (*SignalIdentifier) Reset 

func (x *SignalIdentifier) Reset()

func (*SignalIdentifier) String 

func (x *SignalIdentifier) String() string

type SimpleType 

type SimpleType int32

Define a set of simple types. 

const (
	SimpleType_NONE     SimpleType = 0
	SimpleType_INTEGER  SimpleType = 1
	SimpleType_FLOAT    SimpleType = 2
	SimpleType_STRING   SimpleType = 3
	SimpleType_BOOLEAN  SimpleType = 4
	SimpleType_DATETIME SimpleType = 5
	SimpleType_DURATION SimpleType = 6
	SimpleType_BINARY   SimpleType = 7
	SimpleType_ERROR    SimpleType = 8
	SimpleType_STRUCT   SimpleType = 9
)

func (SimpleType) Descriptor added in v1.10.7 

func (SimpleType) Descriptor() protoreflect.EnumDescriptor

func (SimpleType) Enum added in v1.10.7 

func (x SimpleType) Enum() *SimpleType

func (SimpleType) EnumDescriptor deprecated 

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

Deprecated: Use SimpleType.Descriptor instead.

func (SimpleType) Number added in v1.10.7 

func (x SimpleType) Number() protoreflect.EnumNumber

func (SimpleType) String 

func (x SimpleType) String() string

func (SimpleType) Type added in v1.10.7 

func (SimpleType) Type() protoreflect.EnumType

type SleepCondition 

type SleepCondition struct {

	// The overall duration for this sleep.
	Duration *durationpb.Duration `protobuf:"bytes,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

SleepCondition represents a dependency on waiting for the specified duration.

func (*SleepCondition) Descriptor deprecated 

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

Deprecated: Use SleepCondition.ProtoReflect.Descriptor instead.

func (*SleepCondition) GetDuration 

func (x *SleepCondition) GetDuration() *durationpb.Duration

func (*SleepCondition) ProtoMessage 

func (*SleepCondition) ProtoMessage()

func (*SleepCondition) ProtoReflect added in v1.10.7 

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

func (*SleepCondition) Reset 

func (x *SleepCondition) Reset()

func (*SleepCondition) String 

func (x *SleepCondition) String() string

type Span 

type Span struct {

	// start_time defines the instance this span began.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// end_time defines the instance this span completed.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Types that are assignable to Id:
	//
	//	*Span_WorkflowId
	//	*Span_NodeId
	//	*Span_TaskId
	//	*Span_OperationId
	Id isSpan_Id `protobuf_oneof:"id"`
	// spans defines a collection of Spans that breakdown this execution.
	Spans []*Span `protobuf:"bytes,7,rep,name=spans,proto3" json:"spans,omitempty"`
	// contains filtered or unexported fields
}

Span represents a duration trace of Flyte execution. The id field denotes a Flyte execution entity or an operation which uniquely identifies the Span. The spans attribute allows this Span to be further broken down into more precise definitions.

func (*Span) Descriptor deprecated 

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

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetEndTime 

func (x *Span) GetEndTime() *timestamppb.Timestamp

func (*Span) GetId 

func (m *Span) GetId() isSpan_Id

func (*Span) GetNodeId 

func (x *Span) GetNodeId() *NodeExecutionIdentifier

func (*Span) GetOperationId 

func (x *Span) GetOperationId() string

func (*Span) GetSpans 

func (x *Span) GetSpans() []*Span

func (*Span) GetStartTime 

func (x *Span) GetStartTime() *timestamppb.Timestamp

func (*Span) GetTaskId 

func (x *Span) GetTaskId() *TaskExecutionIdentifier

func (*Span) GetWorkflowId 

func (x *Span) GetWorkflowId() *WorkflowExecutionIdentifier

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) ProtoReflect added in v1.10.7 

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

func (*Span) Reset 

func (x *Span) Reset()

func (*Span) String 

func (x *Span) String() string

type Span_NodeId 

type Span_NodeId struct {
	// node_id is the id of the node execution this Span represents.
	NodeId *NodeExecutionIdentifier `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3,oneof"`
}

type Span_OperationId 

type Span_OperationId struct {
	// operation_id is the id of a unique operation that this Span represents.
	OperationId string `protobuf:"bytes,6,opt,name=operation_id,json=operationId,proto3,oneof"`
}

type Span_TaskId 

type Span_TaskId struct {
	// task_id is the id of the task execution this Span represents.
	TaskId *TaskExecutionIdentifier `protobuf:"bytes,5,opt,name=task_id,json=taskId,proto3,oneof"`
}

type Span_WorkflowId 

type Span_WorkflowId struct {
	// workflow_id is the id of the workflow execution this Span represents.
	WorkflowId *WorkflowExecutionIdentifier `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3,oneof"`
}

type Sql 

type Sql struct {

	// The actual query to run, the query can have templated parameters.
	// We use Flyte's Golang templating format for Query templating.
	// For example,
	// insert overwrite directory '{{ .rawOutputDataPrefix }}' stored as parquet
	// select *
	// from my_table
	// where ds = '{{ .Inputs.ds }}'
	Statement string      `protobuf:"bytes,1,opt,name=statement,proto3" json:"statement,omitempty"`
	Dialect   Sql_Dialect `protobuf:"varint,2,opt,name=dialect,proto3,enum=flyteidl.core.Sql_Dialect" json:"dialect,omitempty"`
	// contains filtered or unexported fields
}

Sql represents a generic sql workload with a statement and dialect.

func (*Sql) Descriptor deprecated 

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

Deprecated: Use Sql.ProtoReflect.Descriptor instead.

func (*Sql) GetDialect 

func (x *Sql) GetDialect() Sql_Dialect

func (*Sql) GetStatement 

func (x *Sql) GetStatement() string

func (*Sql) ProtoMessage 

func (*Sql) ProtoMessage()

func (*Sql) ProtoReflect added in v1.10.7 

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

func (*Sql) Reset 

func (x *Sql) Reset()

func (*Sql) String 

func (x *Sql) String() string

type Sql_Dialect 

type Sql_Dialect int32

The dialect of the SQL statement. This is used to validate and parse SQL statements at compilation time to avoid expensive runtime operations. If set to an unsupported dialect, no validation will be done on the statement. We support the following dialect: ansi, hive. 

const (
	Sql_UNDEFINED Sql_Dialect = 0
	Sql_ANSI      Sql_Dialect = 1
	Sql_HIVE      Sql_Dialect = 2
	Sql_OTHER     Sql_Dialect = 3
)

func (Sql_Dialect) Descriptor added in v1.10.7 

func (Sql_Dialect) Descriptor() protoreflect.EnumDescriptor

func (Sql_Dialect) Enum added in v1.10.7 

func (x Sql_Dialect) Enum() *Sql_Dialect

func (Sql_Dialect) EnumDescriptor deprecated 

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

Deprecated: Use Sql_Dialect.Descriptor instead.

func (Sql_Dialect) Number added in v1.10.7 

func (x Sql_Dialect) Number() protoreflect.EnumNumber

func (Sql_Dialect) String 

func (x Sql_Dialect) String() string

func (Sql_Dialect) Type added in v1.10.7 

func (Sql_Dialect) Type() protoreflect.EnumType

type StructuredDataset 

type StructuredDataset struct {

	// String location uniquely identifying where the data is.
	// Should start with the storage location (e.g. s3://, gs://, bq://, etc.)
	Uri      string                     `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Metadata *StructuredDatasetMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*StructuredDataset) Descriptor deprecated 

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

Deprecated: Use StructuredDataset.ProtoReflect.Descriptor instead.

func (*StructuredDataset) GetMetadata 

func (x *StructuredDataset) GetMetadata() *StructuredDatasetMetadata

func (*StructuredDataset) GetUri 

func (x *StructuredDataset) GetUri() string

func (*StructuredDataset) ProtoMessage 

func (*StructuredDataset) ProtoMessage()

func (*StructuredDataset) ProtoReflect added in v1.10.7 

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

func (*StructuredDataset) Reset 

func (x *StructuredDataset) Reset()

func (*StructuredDataset) String 

func (x *StructuredDataset) String() string

type StructuredDatasetMetadata 

type StructuredDatasetMetadata struct {

	// Bundle the type information along with the literal.
	// This is here because StructuredDatasets can often be more defined at run time than at compile time.
	// That is, at compile time you might only declare a task to return a pandas dataframe or a StructuredDataset,
	// without any column information, but at run time, you might have that column information.
	// flytekit python will copy this type information into the literal, from the type information, if not provided by
	// the various plugins (encoders).
	// Since this field is run time generated, it's not used for any type checking.
	StructuredDatasetType *StructuredDatasetType `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StructuredDatasetMetadata) Descriptor deprecated 

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

Deprecated: Use StructuredDatasetMetadata.ProtoReflect.Descriptor instead.

func (*StructuredDatasetMetadata) GetStructuredDatasetType 

func (x *StructuredDatasetMetadata) GetStructuredDatasetType() *StructuredDatasetType

func (*StructuredDatasetMetadata) ProtoMessage 

func (*StructuredDatasetMetadata) ProtoMessage()

func (*StructuredDatasetMetadata) ProtoReflect added in v1.10.7 

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

func (*StructuredDatasetMetadata) Reset 

func (x *StructuredDatasetMetadata) Reset()

func (*StructuredDatasetMetadata) String 

func (x *StructuredDatasetMetadata) String() string

type StructuredDatasetType 

type StructuredDatasetType struct {

	// A list of ordered columns this schema comprises of.
	Columns []*StructuredDatasetType_DatasetColumn `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// This is the storage format, the format of the bits at rest
	// parquet, feather, csv, etc.
	// For two types to be compatible, the format will need to be an exact match.
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// This is a string representing the type that the bytes in external_schema_bytes are formatted in.
	// This is an optional field that will not be used for type checking.
	ExternalSchemaType string `protobuf:"bytes,3,opt,name=external_schema_type,json=externalSchemaType,proto3" json:"external_schema_type,omitempty"`
	// The serialized bytes of a third-party schema library like Arrow.
	// This is an optional field that will not be used for type checking.
	ExternalSchemaBytes []byte `protobuf:"bytes,4,opt,name=external_schema_bytes,json=externalSchemaBytes,proto3" json:"external_schema_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*StructuredDatasetType) Descriptor deprecated 

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

Deprecated: Use StructuredDatasetType.ProtoReflect.Descriptor instead.

func (*StructuredDatasetType) GetColumns 

func (x *StructuredDatasetType) GetColumns() []*StructuredDatasetType_DatasetColumn

func (*StructuredDatasetType) GetExternalSchemaBytes 

func (x *StructuredDatasetType) GetExternalSchemaBytes() []byte

func (*StructuredDatasetType) GetExternalSchemaType 

func (x *StructuredDatasetType) GetExternalSchemaType() string

func (*StructuredDatasetType) GetFormat 

func (x *StructuredDatasetType) GetFormat() string

func (*StructuredDatasetType) ProtoMessage 

func (*StructuredDatasetType) ProtoMessage()

func (*StructuredDatasetType) ProtoReflect added in v1.10.7 

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

func (*StructuredDatasetType) Reset 

func (x *StructuredDatasetType) Reset()

func (*StructuredDatasetType) String 

func (x *StructuredDatasetType) String() string

type StructuredDatasetType_DatasetColumn 

type StructuredDatasetType_DatasetColumn struct {

	// A unique name within the schema type for the column.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The column type.
	LiteralType *LiteralType `protobuf:"bytes,2,opt,name=literal_type,json=literalType,proto3" json:"literal_type,omitempty"`
	// contains filtered or unexported fields
}

func (*StructuredDatasetType_DatasetColumn) Descriptor deprecated 

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

Deprecated: Use StructuredDatasetType_DatasetColumn.ProtoReflect.Descriptor instead.

func (*StructuredDatasetType_DatasetColumn) GetLiteralType 

func (x *StructuredDatasetType_DatasetColumn) GetLiteralType() *LiteralType

func (*StructuredDatasetType_DatasetColumn) GetName 

func (x *StructuredDatasetType_DatasetColumn) GetName() string

func (*StructuredDatasetType_DatasetColumn) ProtoMessage 

func (*StructuredDatasetType_DatasetColumn) ProtoMessage()

func (*StructuredDatasetType_DatasetColumn) ProtoReflect added in v1.10.7 

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

func (*StructuredDatasetType_DatasetColumn) Reset 

func (x *StructuredDatasetType_DatasetColumn) Reset()

func (*StructuredDatasetType_DatasetColumn) String 

func (x *StructuredDatasetType_DatasetColumn) String() string

type TaskExecution 

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

Phases that task plugins can go through. Not all phases may be applicable to a specific plugin task, but this is the cumulative list that customers may want to know about for their task.

func (*TaskExecution) Descriptor deprecated 

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

Deprecated: Use TaskExecution.ProtoReflect.Descriptor instead.

func (*TaskExecution) ProtoMessage 

func (*TaskExecution) ProtoMessage()

func (*TaskExecution) ProtoReflect added in v1.10.7 

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

func (*TaskExecution) Reset 

func (x *TaskExecution) Reset()

func (*TaskExecution) String 

func (x *TaskExecution) String() string

type TaskExecutionIdentifier 

type TaskExecutionIdentifier struct {
	TaskId          *Identifier              `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	NodeExecutionId *NodeExecutionIdentifier `protobuf:"bytes,2,opt,name=node_execution_id,json=nodeExecutionId,proto3" json:"node_execution_id,omitempty"`
	RetryAttempt    uint32                   `protobuf:"varint,3,opt,name=retry_attempt,json=retryAttempt,proto3" json:"retry_attempt,omitempty"`
	// contains filtered or unexported fields
}

Encapsulation of fields that identify a Flyte task execution entity.

func (*TaskExecutionIdentifier) Descriptor deprecated 

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

Deprecated: Use TaskExecutionIdentifier.ProtoReflect.Descriptor instead.

func (*TaskExecutionIdentifier) GetNodeExecutionId 

func (x *TaskExecutionIdentifier) GetNodeExecutionId() *NodeExecutionIdentifier

func (*TaskExecutionIdentifier) GetRetryAttempt 

func (x *TaskExecutionIdentifier) GetRetryAttempt() uint32

func (*TaskExecutionIdentifier) GetTaskId 

func (x *TaskExecutionIdentifier) GetTaskId() *Identifier

func (*TaskExecutionIdentifier) ProtoMessage 

func (*TaskExecutionIdentifier) ProtoMessage()

func (*TaskExecutionIdentifier) ProtoReflect added in v1.10.7 

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

func (*TaskExecutionIdentifier) Reset 

func (x *TaskExecutionIdentifier) Reset()

func (*TaskExecutionIdentifier) String 

func (x *TaskExecutionIdentifier) String() string

type TaskExecution_Phase 

type TaskExecution_Phase int32
const (
	TaskExecution_UNDEFINED TaskExecution_Phase = 0
	TaskExecution_QUEUED    TaskExecution_Phase = 1
	TaskExecution_RUNNING   TaskExecution_Phase = 2
	TaskExecution_SUCCEEDED TaskExecution_Phase = 3
	TaskExecution_ABORTED   TaskExecution_Phase = 4
	TaskExecution_FAILED    TaskExecution_Phase = 5
	// To indicate cases where task is initializing, like: ErrImagePull, ContainerCreating, PodInitializing
	TaskExecution_INITIALIZING TaskExecution_Phase = 6
	// To address cases, where underlying resource is not available: Backoff error, Resource quota exceeded
	TaskExecution_WAITING_FOR_RESOURCES TaskExecution_Phase = 7
)

func (TaskExecution_Phase) Descriptor added in v1.10.7 

func (TaskExecution_Phase) Descriptor() protoreflect.EnumDescriptor

func (TaskExecution_Phase) Enum added in v1.10.7 

func (x TaskExecution_Phase) Enum() *TaskExecution_Phase

func (TaskExecution_Phase) EnumDescriptor deprecated 

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

Deprecated: Use TaskExecution_Phase.Descriptor instead.

func (TaskExecution_Phase) Number added in v1.10.7 

func (x TaskExecution_Phase) Number() protoreflect.EnumNumber

func (TaskExecution_Phase) String 

func (x TaskExecution_Phase) String() string

func (TaskExecution_Phase) Type added in v1.10.7 

func (TaskExecution_Phase) Type() protoreflect.EnumType

type TaskLog 

type TaskLog struct {
	Uri           string                `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	Name          string                `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	MessageFormat TaskLog_MessageFormat `` /* 142-byte string literal not displayed */
	Ttl           *durationpb.Duration  `protobuf:"bytes,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

Log information for the task that is specific to a log sink When our log story is flushed out, we may have more metadata here like log link expiry

func (*TaskLog) Descriptor deprecated 

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

Deprecated: Use TaskLog.ProtoReflect.Descriptor instead.

func (*TaskLog) GetMessageFormat 

func (x *TaskLog) GetMessageFormat() TaskLog_MessageFormat

func (*TaskLog) GetName 

func (x *TaskLog) GetName() string

func (*TaskLog) GetTtl 

func (x *TaskLog) GetTtl() *durationpb.Duration

func (*TaskLog) GetUri 

func (x *TaskLog) GetUri() string

func (*TaskLog) ProtoMessage 

func (*TaskLog) ProtoMessage()

func (*TaskLog) ProtoReflect added in v1.10.7 

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

func (*TaskLog) Reset 

func (x *TaskLog) Reset()

func (*TaskLog) String 

func (x *TaskLog) String() string

type TaskLog_MessageFormat 

type TaskLog_MessageFormat int32
const (
	TaskLog_UNKNOWN TaskLog_MessageFormat = 0
	TaskLog_CSV     TaskLog_MessageFormat = 1
	TaskLog_JSON    TaskLog_MessageFormat = 2
)

func (TaskLog_MessageFormat) Descriptor added in v1.10.7 

func (TaskLog_MessageFormat) Descriptor() protoreflect.EnumDescriptor

func (TaskLog_MessageFormat) Enum added in v1.10.7 

func (x TaskLog_MessageFormat) Enum() *TaskLog_MessageFormat

func (TaskLog_MessageFormat) EnumDescriptor deprecated 

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

Deprecated: Use TaskLog_MessageFormat.Descriptor instead.

func (TaskLog_MessageFormat) Number added in v1.10.7 

func (x TaskLog_MessageFormat) Number() protoreflect.EnumNumber

func (TaskLog_MessageFormat) String 

func (x TaskLog_MessageFormat) String() string

func (TaskLog_MessageFormat) Type added in v1.10.7 

func (TaskLog_MessageFormat) Type() protoreflect.EnumType

type TaskMetadata 

type TaskMetadata struct {

	// Indicates whether the system should attempt to lookup this task's output to avoid duplication of work.
	Discoverable bool `protobuf:"varint,1,opt,name=discoverable,proto3" json:"discoverable,omitempty"`
	// Runtime information about the task.
	Runtime *RuntimeMetadata `protobuf:"bytes,2,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// The overall timeout of a task including user-triggered retries.
	Timeout *durationpb.Duration `protobuf:"bytes,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Number of retries per task.
	Retries *RetryStrategy `protobuf:"bytes,5,opt,name=retries,proto3" json:"retries,omitempty"`
	// Indicates a logical version to apply to this task for the purpose of discovery.
	DiscoveryVersion string `protobuf:"bytes,6,opt,name=discovery_version,json=discoveryVersion,proto3" json:"discovery_version,omitempty"`
	// If set, this indicates that this task is deprecated.  This will enable owners of tasks to notify consumers
	// of the ending of support for a given task.
	DeprecatedErrorMessage string `` /* 129-byte string literal not displayed */
	// Identify whether task is interruptible
	//
	// Types that are assignable to InterruptibleValue:
	//
	//	*TaskMetadata_Interruptible
	InterruptibleValue isTaskMetadata_InterruptibleValue `protobuf_oneof:"interruptible_value"`
	// Indicates whether the system should attempt to execute discoverable instances in serial to avoid duplicate work
	CacheSerializable bool `protobuf:"varint,9,opt,name=cache_serializable,json=cacheSerializable,proto3" json:"cache_serializable,omitempty"`
	// Indicates whether the task will generate a Deck URI when it finishes executing.
	GeneratesDeck bool `protobuf:"varint,10,opt,name=generates_deck,json=generatesDeck,proto3" json:"generates_deck,omitempty"`
	// Arbitrary tags that allow users and the platform to store small but arbitrary labels
	Tags map[string]string `` /* 150-byte string literal not displayed */
	// pod_template_name is the unique name of a PodTemplate k8s resource to be used as the base configuration if this
	// task creates a k8s Pod. If this value is set, the specified PodTemplate will be used instead of, but applied
	// identically as, the default PodTemplate configured in FlytePropeller.
	PodTemplateName string `protobuf:"bytes,12,opt,name=pod_template_name,json=podTemplateName,proto3" json:"pod_template_name,omitempty"`
	// cache_ignore_input_vars is the input variables that should not be included when calculating hash for cache.
	CacheIgnoreInputVars []string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Task Metadata

func (*TaskMetadata) Descriptor deprecated 

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

Deprecated: Use TaskMetadata.ProtoReflect.Descriptor instead.

func (*TaskMetadata) GetCacheIgnoreInputVars added in v1.10.7 

func (x *TaskMetadata) GetCacheIgnoreInputVars() []string

func (*TaskMetadata) GetCacheSerializable 

func (x *TaskMetadata) GetCacheSerializable() bool

func (*TaskMetadata) GetDeprecatedErrorMessage 

func (x *TaskMetadata) GetDeprecatedErrorMessage() string

func (*TaskMetadata) GetDiscoverable 

func (x *TaskMetadata) GetDiscoverable() bool

func (*TaskMetadata) GetDiscoveryVersion 

func (x *TaskMetadata) GetDiscoveryVersion() string

func (*TaskMetadata) GetGeneratesDeck 

func (x *TaskMetadata) GetGeneratesDeck() bool

func (*TaskMetadata) GetInterruptible 

func (x *TaskMetadata) GetInterruptible() bool

func (*TaskMetadata) GetInterruptibleValue 

func (m *TaskMetadata) GetInterruptibleValue() isTaskMetadata_InterruptibleValue

func (*TaskMetadata) GetPodTemplateName 

func (x *TaskMetadata) GetPodTemplateName() string

func (*TaskMetadata) GetRetries 

func (x *TaskMetadata) GetRetries() *RetryStrategy

func (*TaskMetadata) GetRuntime 

func (x *TaskMetadata) GetRuntime() *RuntimeMetadata

func (*TaskMetadata) GetTags 

func (x *TaskMetadata) GetTags() map[string]string

func (*TaskMetadata) GetTimeout 

func (x *TaskMetadata) GetTimeout() *durationpb.Duration

func (*TaskMetadata) ProtoMessage 

func (*TaskMetadata) ProtoMessage()

func (*TaskMetadata) ProtoReflect added in v1.10.7 

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

func (*TaskMetadata) Reset 

func (x *TaskMetadata) Reset()

func (*TaskMetadata) String 

func (x *TaskMetadata) String() string

type TaskMetadata_Interruptible 

type TaskMetadata_Interruptible struct {
	Interruptible bool `protobuf:"varint,8,opt,name=interruptible,proto3,oneof"`
}

type TaskNode 

type TaskNode struct {

	// Types that are assignable to Reference:
	//
	//	*TaskNode_ReferenceId
	Reference isTaskNode_Reference `protobuf_oneof:"reference"`
	// Optional overrides applied at task execution time.
	Overrides *TaskNodeOverrides `protobuf:"bytes,2,opt,name=overrides,proto3" json:"overrides,omitempty"`
	// contains filtered or unexported fields
}

Refers to the task that the Node is to execute.

func (*TaskNode) Descriptor deprecated 

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

Deprecated: Use TaskNode.ProtoReflect.Descriptor instead.

func (*TaskNode) GetOverrides 

func (x *TaskNode) GetOverrides() *TaskNodeOverrides

func (*TaskNode) GetReference 

func (m *TaskNode) GetReference() isTaskNode_Reference

func (*TaskNode) GetReferenceId 

func (x *TaskNode) GetReferenceId() *Identifier

func (*TaskNode) ProtoMessage 

func (*TaskNode) ProtoMessage()

func (*TaskNode) ProtoReflect added in v1.10.7 

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

func (*TaskNode) Reset 

func (x *TaskNode) Reset()

func (*TaskNode) String 

func (x *TaskNode) String() string

type TaskNodeOverrides 

type TaskNodeOverrides struct {

	// A customizable interface to convey resources requested for a task container.
	Resources *Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources,omitempty"`
	// Overrides for all non-standard resources, not captured by
	// v1.ResourceRequirements, to allocate to a task.
	ExtendedResources *ExtendedResources `protobuf:"bytes,2,opt,name=extended_resources,json=extendedResources,proto3" json:"extended_resources,omitempty"`
	// Override for the image used by task pods.
	ContainerImage string `protobuf:"bytes,3,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"`
	// contains filtered or unexported fields
}

Optional task node overrides that will be applied at task execution time.

func (*TaskNodeOverrides) Descriptor deprecated 

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

Deprecated: Use TaskNodeOverrides.ProtoReflect.Descriptor instead.

func (*TaskNodeOverrides) GetContainerImage added in v1.11.0 

func (x *TaskNodeOverrides) GetContainerImage() string

func (*TaskNodeOverrides) GetExtendedResources added in v1.9.20 

func (x *TaskNodeOverrides) GetExtendedResources() *ExtendedResources

func (*TaskNodeOverrides) GetResources 

func (x *TaskNodeOverrides) GetResources() *Resources

func (*TaskNodeOverrides) ProtoMessage 

func (*TaskNodeOverrides) ProtoMessage()

func (*TaskNodeOverrides) ProtoReflect added in v1.10.7 

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

func (*TaskNodeOverrides) Reset 

func (x *TaskNodeOverrides) Reset()

func (*TaskNodeOverrides) String 

func (x *TaskNodeOverrides) String() string

type TaskNode_ReferenceId 

type TaskNode_ReferenceId struct {
	// A globally unique identifier for the task.
	ReferenceId *Identifier `protobuf:"bytes,1,opt,name=reference_id,json=referenceId,proto3,oneof"`
}

type TaskTemplate 

type TaskTemplate struct {

	// Auto generated taskId by the system. Task Id uniquely identifies this task globally.
	Id *Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// A predefined yet extensible Task type identifier. This can be used to customize any of the components. If no
	// extensions are provided in the system, Flyte will resolve the this task to its TaskCategory and default the
	// implementation registered for the TaskCategory.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Extra metadata about the task.
	Metadata *TaskMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// A strongly typed interface for the task. This enables others to use this task within a workflow and guarantees
	// compile-time validation of the workflow to avoid costly runtime failures.
	Interface *TypedInterface `protobuf:"bytes,4,opt,name=interface,proto3" json:"interface,omitempty"`
	// Custom data about the task. This is extensible to allow various plugins in the system.
	Custom *structpb.Struct `protobuf:"bytes,5,opt,name=custom,proto3" json:"custom,omitempty"`
	// Known target types that the system will guarantee plugins for. Custom SDK plugins are allowed to set these if needed.
	// If no corresponding execution-layer plugins are found, the system will default to handling these using built-in
	// handlers.
	//
	// Types that are assignable to Target:
	//
	//	*TaskTemplate_Container
	//	*TaskTemplate_K8SPod
	//	*TaskTemplate_Sql
	Target isTaskTemplate_Target `protobuf_oneof:"target"`
	// This can be used to customize task handling at execution time for the same task type.
	TaskTypeVersion int32 `protobuf:"varint,7,opt,name=task_type_version,json=taskTypeVersion,proto3" json:"task_type_version,omitempty"`
	// security_context encapsulates security attributes requested to run this task.
	SecurityContext *SecurityContext `protobuf:"bytes,8,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// Encapsulates all non-standard resources, not captured by
	// v1.ResourceRequirements, to allocate to a task.
	ExtendedResources *ExtendedResources `protobuf:"bytes,9,opt,name=extended_resources,json=extendedResources,proto3" json:"extended_resources,omitempty"`
	// Metadata about the custom defined for this task. This is extensible to allow various plugins in the system
	// to use as required.
	// reserve the field numbers 1 through 15 for very frequently occurring message elements
	Config map[string]string `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

A Task structure that uniquely identifies a task in the system Tasks are registered as a first step in the system.

func (*TaskTemplate) Descriptor deprecated 

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

Deprecated: Use TaskTemplate.ProtoReflect.Descriptor instead.

func (*TaskTemplate) GetConfig 

func (x *TaskTemplate) GetConfig() map[string]string

func (*TaskTemplate) GetContainer 

func (x *TaskTemplate) GetContainer() *Container

func (*TaskTemplate) GetCustom 

func (x *TaskTemplate) GetCustom() *structpb.Struct

func (*TaskTemplate) GetExtendedResources added in v1.9.20 

func (x *TaskTemplate) GetExtendedResources() *ExtendedResources

func (*TaskTemplate) GetId 

func (x *TaskTemplate) GetId() *Identifier

func (*TaskTemplate) GetInterface 

func (x *TaskTemplate) GetInterface() *TypedInterface

func (*TaskTemplate) GetK8SPod 

func (x *TaskTemplate) GetK8SPod() *K8SPod

func (*TaskTemplate) GetMetadata 

func (x *TaskTemplate) GetMetadata() *TaskMetadata

func (*TaskTemplate) GetSecurityContext 

func (x *TaskTemplate) GetSecurityContext() *SecurityContext

func (*TaskTemplate) GetSql 

func (x *TaskTemplate) GetSql() *Sql

func (*TaskTemplate) GetTarget 

func (m *TaskTemplate) GetTarget() isTaskTemplate_Target

func (*TaskTemplate) GetTaskTypeVersion 

func (x *TaskTemplate) GetTaskTypeVersion() int32

func (*TaskTemplate) GetType 

func (x *TaskTemplate) GetType() string

func (*TaskTemplate) ProtoMessage 

func (*TaskTemplate) ProtoMessage()

func (*TaskTemplate) ProtoReflect added in v1.10.7 

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

func (*TaskTemplate) Reset 

func (x *TaskTemplate) Reset()

func (*TaskTemplate) String 

func (x *TaskTemplate) String() string

type TaskTemplate_Container 

type TaskTemplate_Container struct {
	Container *Container `protobuf:"bytes,6,opt,name=container,proto3,oneof"`
}

type TaskTemplate_K8SPod 

type TaskTemplate_K8SPod struct {
	K8SPod *K8SPod `protobuf:"bytes,17,opt,name=k8s_pod,json=k8sPod,proto3,oneof"`
}

type TaskTemplate_Sql 

type TaskTemplate_Sql struct {
	Sql *Sql `protobuf:"bytes,18,opt,name=sql,proto3,oneof"`
}

type TimePartition added in v1.10.7 

type TimePartition struct {
	Value       *LabelValue `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Granularity Granularity `protobuf:"varint,2,opt,name=granularity,proto3,enum=flyteidl.core.Granularity" json:"granularity,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use TimePartition.ProtoReflect.Descriptor instead.

func (*TimePartition) GetGranularity added in v1.11.0 

func (x *TimePartition) GetGranularity() Granularity

func (*TimePartition) GetValue added in v1.10.7 

func (x *TimePartition) GetValue() *LabelValue

func (*TimePartition) ProtoMessage added in v1.10.7 

func (*TimePartition) ProtoMessage()

func (*TimePartition) ProtoReflect added in v1.10.7 

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

func (*TimePartition) Reset added in v1.10.7 

func (x *TimePartition) Reset()

func (*TimePartition) String added in v1.10.7 

func (x *TimePartition) String() string

type TimeTransform added in v1.11.0 

type TimeTransform struct {
	Transform string   `protobuf:"bytes,1,opt,name=transform,proto3" json:"transform,omitempty"`
	Op        Operator `protobuf:"varint,2,opt,name=op,proto3,enum=flyteidl.core.Operator" json:"op,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeTransform) Descriptor deprecated added in v1.11.0 

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

Deprecated: Use TimeTransform.ProtoReflect.Descriptor instead.

func (*TimeTransform) GetOp added in v1.11.0 

func (x *TimeTransform) GetOp() Operator

func (*TimeTransform) GetTransform added in v1.11.0 

func (x *TimeTransform) GetTransform() string

func (*TimeTransform) ProtoMessage added in v1.11.0 

func (*TimeTransform) ProtoMessage()

func (*TimeTransform) ProtoReflect added in v1.11.0 

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

func (*TimeTransform) Reset added in v1.11.0 

func (x *TimeTransform) Reset()

func (*TimeTransform) String added in v1.11.0 

func (x *TimeTransform) String() string

type TypeAnnotation 

type TypeAnnotation struct {

	// A arbitrary JSON payload to describe a type.
	Annotations *structpb.Struct `protobuf:"bytes,1,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// contains filtered or unexported fields
}

TypeAnnotation encapsulates registration time information about a type. This can be used for various control-plane operations. TypeAnnotation will not be available at runtime when a task runs.

func (*TypeAnnotation) Descriptor deprecated 

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

Deprecated: Use TypeAnnotation.ProtoReflect.Descriptor instead.

func (*TypeAnnotation) GetAnnotations 

func (x *TypeAnnotation) GetAnnotations() *structpb.Struct

func (*TypeAnnotation) ProtoMessage 

func (*TypeAnnotation) ProtoMessage()

func (*TypeAnnotation) ProtoReflect added in v1.10.7 

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

func (*TypeAnnotation) Reset 

func (x *TypeAnnotation) Reset()

func (*TypeAnnotation) String 

func (x *TypeAnnotation) String() string

type TypeStructure 

type TypeStructure struct {

	// Must exactly match for types to be castable
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// dataclass_type only exists for dataclasses.
	// This is used to resolve the type of the fields of dataclass
	// The key is the field name, and the value is the literal type of the field
	// e.g. For dataclass Foo, with fields a, and a is a string
	// Foo.a will be resolved as a literal type of string from dataclass_type
	DataclassType map[string]*LiteralType `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

Hints to improve type matching e.g. allows distinguishing output from custom type transformers even if the underlying IDL serialization matches.

func (*TypeStructure) Descriptor deprecated 

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

Deprecated: Use TypeStructure.ProtoReflect.Descriptor instead.

func (*TypeStructure) GetDataclassType added in v1.9.33 

func (x *TypeStructure) GetDataclassType() map[string]*LiteralType

func (*TypeStructure) GetTag 

func (x *TypeStructure) GetTag() string

func (*TypeStructure) ProtoMessage 

func (*TypeStructure) ProtoMessage()

func (*TypeStructure) ProtoReflect added in v1.10.7 

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

func (*TypeStructure) Reset 

func (x *TypeStructure) Reset()

func (*TypeStructure) String 

func (x *TypeStructure) String() string

type TypedInterface 

type TypedInterface struct {
	Inputs  *VariableMap `protobuf:"bytes,1,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs *VariableMap `protobuf:"bytes,2,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

Defines strongly typed inputs and outputs.

func (*TypedInterface) Descriptor deprecated 

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

Deprecated: Use TypedInterface.ProtoReflect.Descriptor instead.

func (*TypedInterface) GetInputs 

func (x *TypedInterface) GetInputs() *VariableMap

func (*TypedInterface) GetOutputs 

func (x *TypedInterface) GetOutputs() *VariableMap

func (*TypedInterface) ProtoMessage 

func (*TypedInterface) ProtoMessage()

func (*TypedInterface) ProtoReflect added in v1.10.7 

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

func (*TypedInterface) Reset 

func (x *TypedInterface) Reset()

func (*TypedInterface) String 

func (x *TypedInterface) String() string

type Union 

type Union struct {
	Value *Literal     `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Type  *LiteralType `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

The runtime representation of a tagged union value. See `UnionType` for more details.

func (*Union) Descriptor deprecated 

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

Deprecated: Use Union.ProtoReflect.Descriptor instead.

func (*Union) GetType 

func (x *Union) GetType() *LiteralType

func (*Union) GetValue 

func (x *Union) GetValue() *Literal

func (*Union) ProtoMessage 

func (*Union) ProtoMessage()

func (*Union) ProtoReflect added in v1.10.7 

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

func (*Union) Reset 

func (x *Union) Reset()

func (*Union) String 

func (x *Union) String() string

type UnionInfo 

type UnionInfo struct {
	TargetType *LiteralType `protobuf:"bytes,1,opt,name=targetType,proto3" json:"targetType,omitempty"`
	// contains filtered or unexported fields
}

func (*UnionInfo) Descriptor deprecated 

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

Deprecated: Use UnionInfo.ProtoReflect.Descriptor instead.

func (*UnionInfo) GetTargetType 

func (x *UnionInfo) GetTargetType() *LiteralType

func (*UnionInfo) ProtoMessage 

func (*UnionInfo) ProtoMessage()

func (*UnionInfo) ProtoReflect added in v1.10.7 

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

func (*UnionInfo) Reset 

func (x *UnionInfo) Reset()

func (*UnionInfo) String 

func (x *UnionInfo) String() string

type UnionType 

type UnionType struct {

	// Predefined set of variants in union.
	Variants []*LiteralType `protobuf:"bytes,1,rep,name=variants,proto3" json:"variants,omitempty"`
	// contains filtered or unexported fields
}

Defines a tagged union type, also known as a variant (and formally as the sum type).

A sum type S is defined by a sequence of types (A, B, C, ...), each tagged by a string tag A value of type S is constructed from a value of any of the variant types. The specific choice of type is recorded by storing the varaint's tag with the literal value and can be examined in runtime.

Type S is typically written as S := Apple A | Banana B | Cantaloupe C | ...

Notably, a nullable (optional) type is a sum type between some type X and the singleton type representing a null-value: Optional X := X | Null

See also: https://en.wikipedia.org/wiki/Tagged_union

func (*UnionType) Descriptor deprecated 

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

Deprecated: Use UnionType.ProtoReflect.Descriptor instead.

func (*UnionType) GetVariants 

func (x *UnionType) GetVariants() []*LiteralType

func (*UnionType) ProtoMessage 

func (*UnionType) ProtoMessage()

func (*UnionType) ProtoReflect added in v1.10.7 

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

func (*UnionType) Reset 

func (x *UnionType) Reset()

func (*UnionType) String 

func (x *UnionType) String() string

type Variable 

type Variable struct {

	// Variable literal type.
	Type *LiteralType `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// +optional string describing input variable
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// +optional This object allows the user to specify how Artifacts are created.
	// name, tag, partitions can be specified. The other fields (version and project/domain) are ignored.
	ArtifactPartialId *ArtifactID  `protobuf:"bytes,3,opt,name=artifact_partial_id,json=artifactPartialId,proto3" json:"artifact_partial_id,omitempty"`
	ArtifactTag       *ArtifactTag `protobuf:"bytes,4,opt,name=artifact_tag,json=artifactTag,proto3" json:"artifact_tag,omitempty"`
	// contains filtered or unexported fields
}

Defines a strongly typed variable.

func (*Variable) Descriptor deprecated 

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

Deprecated: Use Variable.ProtoReflect.Descriptor instead.

func (*Variable) GetArtifactPartialId added in v1.10.7 

func (x *Variable) GetArtifactPartialId() *ArtifactID

func (*Variable) GetArtifactTag added in v1.10.7 

func (x *Variable) GetArtifactTag() *ArtifactTag

func (*Variable) GetDescription 

func (x *Variable) GetDescription() string

func (*Variable) GetType 

func (x *Variable) GetType() *LiteralType

func (*Variable) ProtoMessage 

func (*Variable) ProtoMessage()

func (*Variable) ProtoReflect added in v1.10.7 

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

func (*Variable) Reset 

func (x *Variable) Reset()

func (*Variable) String 

func (x *Variable) String() string

type VariableMap 

type VariableMap struct {

	// Defines a map of variable names to variables.
	Variables map[string]*Variable `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

A map of Variables

func (*VariableMap) Descriptor deprecated 

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

Deprecated: Use VariableMap.ProtoReflect.Descriptor instead.

func (*VariableMap) GetVariables 

func (x *VariableMap) GetVariables() map[string]*Variable

func (*VariableMap) ProtoMessage 

func (*VariableMap) ProtoMessage()

func (*VariableMap) ProtoReflect added in v1.10.7 

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

func (*VariableMap) Reset 

func (x *VariableMap) Reset()

func (*VariableMap) String 

func (x *VariableMap) String() string

type Void 

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

Used to denote a nil/null/None assignment to a scalar value. The underlying LiteralType for Void is intentionally undefined since it can be assigned to a scalar of any LiteralType.

func (*Void) Descriptor deprecated 

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) ProtoReflect added in v1.10.7 

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

func (*Void) Reset 

func (x *Void) Reset()

func (*Void) String 

func (x *Void) String() string

type WorkflowClosure 

type WorkflowClosure struct {

	// required. Workflow template.
	Workflow *WorkflowTemplate `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// optional. A collection of tasks referenced by the workflow. Only needed if the workflow
	// references tasks.
	Tasks []*TaskTemplate `protobuf:"bytes,2,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

Defines an enclosed package of workflow and tasks it references.

func (*WorkflowClosure) Descriptor deprecated 

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

Deprecated: Use WorkflowClosure.ProtoReflect.Descriptor instead.

func (*WorkflowClosure) GetTasks 

func (x *WorkflowClosure) GetTasks() []*TaskTemplate

func (*WorkflowClosure) GetWorkflow 

func (x *WorkflowClosure) GetWorkflow() *WorkflowTemplate

func (*WorkflowClosure) ProtoMessage 

func (*WorkflowClosure) ProtoMessage()

func (*WorkflowClosure) ProtoReflect added in v1.10.7 

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

func (*WorkflowClosure) Reset 

func (x *WorkflowClosure) Reset()

func (*WorkflowClosure) String 

func (x *WorkflowClosure) String() string

type WorkflowExecution 

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

Indicates various phases of Workflow Execution

func (*WorkflowExecution) Descriptor deprecated 

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

Deprecated: Use WorkflowExecution.ProtoReflect.Descriptor instead.

func (*WorkflowExecution) ProtoMessage 

func (*WorkflowExecution) ProtoMessage()

func (*WorkflowExecution) ProtoReflect added in v1.10.7 

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

func (*WorkflowExecution) Reset 

func (x *WorkflowExecution) Reset()

func (*WorkflowExecution) String 

func (x *WorkflowExecution) String() string

type WorkflowExecutionIdentifier 

type WorkflowExecutionIdentifier struct {

	// Name of the project the resource belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Name of the domain the resource belongs to.
	// A domain can be considered as a subset within a specific project.
	Domain string `protobuf:"bytes,2,opt,name=domain,proto3" json:"domain,omitempty"`
	// User or system provided value for the resource.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// Optional, org key applied to the resource.
	Org string `protobuf:"bytes,5,opt,name=org,proto3" json:"org,omitempty"`
	// contains filtered or unexported fields
}

Encapsulation of fields that uniquely identifies a Flyte workflow execution

func (*WorkflowExecutionIdentifier) Descriptor deprecated 

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

Deprecated: Use WorkflowExecutionIdentifier.ProtoReflect.Descriptor instead.

func (*WorkflowExecutionIdentifier) GetDomain 

func (x *WorkflowExecutionIdentifier) GetDomain() string

func (*WorkflowExecutionIdentifier) GetName 

func (x *WorkflowExecutionIdentifier) GetName() string

func (*WorkflowExecutionIdentifier) GetOrg added in v1.10.7 

func (x *WorkflowExecutionIdentifier) GetOrg() string

func (*WorkflowExecutionIdentifier) GetProject 

func (x *WorkflowExecutionIdentifier) GetProject() string

func (*WorkflowExecutionIdentifier) ProtoMessage 

func (*WorkflowExecutionIdentifier) ProtoMessage()

func (*WorkflowExecutionIdentifier) ProtoReflect added in v1.10.7 

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

func (*WorkflowExecutionIdentifier) Reset 

func (x *WorkflowExecutionIdentifier) Reset()

func (*WorkflowExecutionIdentifier) String 

func (x *WorkflowExecutionIdentifier) String() string

type WorkflowExecution_Phase 

type WorkflowExecution_Phase int32
const (
	WorkflowExecution_UNDEFINED  WorkflowExecution_Phase = 0
	WorkflowExecution_QUEUED     WorkflowExecution_Phase = 1
	WorkflowExecution_RUNNING    WorkflowExecution_Phase = 2
	WorkflowExecution_SUCCEEDING WorkflowExecution_Phase = 3
	WorkflowExecution_SUCCEEDED  WorkflowExecution_Phase = 4
	WorkflowExecution_FAILING    WorkflowExecution_Phase = 5
	WorkflowExecution_FAILED     WorkflowExecution_Phase = 6
	WorkflowExecution_ABORTED    WorkflowExecution_Phase = 7
	WorkflowExecution_TIMED_OUT  WorkflowExecution_Phase = 8
	WorkflowExecution_ABORTING   WorkflowExecution_Phase = 9
)

func (WorkflowExecution_Phase) Descriptor added in v1.10.7 

func (WorkflowExecution_Phase) Descriptor() protoreflect.EnumDescriptor

func (WorkflowExecution_Phase) Enum added in v1.10.7 

func (x WorkflowExecution_Phase) Enum() *WorkflowExecution_Phase

func (WorkflowExecution_Phase) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowExecution_Phase.Descriptor instead.

func (WorkflowExecution_Phase) Number added in v1.10.7 

func (x WorkflowExecution_Phase) Number() protoreflect.EnumNumber

func (WorkflowExecution_Phase) String 

func (x WorkflowExecution_Phase) String() string

func (WorkflowExecution_Phase) Type added in v1.10.7 

func (WorkflowExecution_Phase) Type() protoreflect.EnumType

type WorkflowMetadata 

type WorkflowMetadata struct {

	// Indicates the runtime priority of workflow executions.
	QualityOfService *QualityOfService `protobuf:"bytes,1,opt,name=quality_of_service,json=qualityOfService,proto3" json:"quality_of_service,omitempty"`
	// Defines how the system should behave when a failure is detected in the workflow execution.
	OnFailure WorkflowMetadata_OnFailurePolicy `` /* 141-byte string literal not displayed */
	// Arbitrary tags that allow users and the platform to store small but arbitrary labels
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

This is workflow layer metadata. These settings are only applicable to the workflow as a whole, and do not percolate down to child entities (like tasks) launched by the workflow.

func (*WorkflowMetadata) Descriptor deprecated 

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

Deprecated: Use WorkflowMetadata.ProtoReflect.Descriptor instead.

func (*WorkflowMetadata) GetOnFailure 

func (x *WorkflowMetadata) GetOnFailure() WorkflowMetadata_OnFailurePolicy

func (*WorkflowMetadata) GetQualityOfService 

func (x *WorkflowMetadata) GetQualityOfService() *QualityOfService

func (*WorkflowMetadata) GetTags 

func (x *WorkflowMetadata) GetTags() map[string]string

func (*WorkflowMetadata) ProtoMessage 

func (*WorkflowMetadata) ProtoMessage()

func (*WorkflowMetadata) ProtoReflect added in v1.10.7 

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

func (*WorkflowMetadata) Reset 

func (x *WorkflowMetadata) Reset()

func (*WorkflowMetadata) String 

func (x *WorkflowMetadata) String() string

type WorkflowMetadataDefaults 

type WorkflowMetadataDefaults struct {

	// Whether child nodes of the workflow are interruptible.
	Interruptible bool `protobuf:"varint,1,opt,name=interruptible,proto3" json:"interruptible,omitempty"`
	// contains filtered or unexported fields
}

The difference between these settings and the WorkflowMetadata ones is that these are meant to be passed down to a workflow's underlying entities (like tasks). For instance, 'interruptible' has no meaning at the workflow layer, it is only relevant when a task executes. The settings here are the defaults that are passed to all nodes unless explicitly overridden at the node layer. If you are adding a setting that applies to both the Workflow itself, and everything underneath it, it should be added to both this object and the WorkflowMetadata object above.

func (*WorkflowMetadataDefaults) Descriptor deprecated 

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

Deprecated: Use WorkflowMetadataDefaults.ProtoReflect.Descriptor instead.

func (*WorkflowMetadataDefaults) GetInterruptible 

func (x *WorkflowMetadataDefaults) GetInterruptible() bool

func (*WorkflowMetadataDefaults) ProtoMessage 

func (*WorkflowMetadataDefaults) ProtoMessage()

func (*WorkflowMetadataDefaults) ProtoReflect added in v1.10.7 

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

func (*WorkflowMetadataDefaults) Reset 

func (x *WorkflowMetadataDefaults) Reset()

func (*WorkflowMetadataDefaults) String 

func (x *WorkflowMetadataDefaults) String() string

type WorkflowMetadata_OnFailurePolicy 

type WorkflowMetadata_OnFailurePolicy int32

Failure Handling Strategy 

const (
	// FAIL_IMMEDIATELY instructs the system to fail as soon as a node fails in the workflow. It'll automatically
	// abort all currently running nodes and clean up resources before finally marking the workflow executions as
	// failed.
	WorkflowMetadata_FAIL_IMMEDIATELY WorkflowMetadata_OnFailurePolicy = 0
	// FAIL_AFTER_EXECUTABLE_NODES_COMPLETE instructs the system to make as much progress as it can. The system will
	// not alter the dependencies of the execution graph so any node that depend on the failed node will not be run.
	// Other nodes that will be executed to completion before cleaning up resources and marking the workflow
	// execution as failed.
	WorkflowMetadata_FAIL_AFTER_EXECUTABLE_NODES_COMPLETE WorkflowMetadata_OnFailurePolicy = 1
)

func (WorkflowMetadata_OnFailurePolicy) Descriptor added in v1.10.7 

func (WorkflowMetadata_OnFailurePolicy) Descriptor() protoreflect.EnumDescriptor

func (WorkflowMetadata_OnFailurePolicy) Enum added in v1.10.7 

func (x WorkflowMetadata_OnFailurePolicy) Enum() *WorkflowMetadata_OnFailurePolicy

func (WorkflowMetadata_OnFailurePolicy) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowMetadata_OnFailurePolicy.Descriptor instead.

func (WorkflowMetadata_OnFailurePolicy) Number added in v1.10.7 

func (x WorkflowMetadata_OnFailurePolicy) Number() protoreflect.EnumNumber

func (WorkflowMetadata_OnFailurePolicy) String 

func (x WorkflowMetadata_OnFailurePolicy) String() string

func (WorkflowMetadata_OnFailurePolicy) Type added in v1.10.7 

func (WorkflowMetadata_OnFailurePolicy) Type() protoreflect.EnumType

type WorkflowNode 

type WorkflowNode struct {

	// Types that are assignable to Reference:
	//
	//	*WorkflowNode_LaunchplanRef
	//	*WorkflowNode_SubWorkflowRef
	Reference isWorkflowNode_Reference `protobuf_oneof:"reference"`
	// contains filtered or unexported fields
}

Refers to a the workflow the node is to execute.

func (*WorkflowNode) Descriptor deprecated 

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

Deprecated: Use WorkflowNode.ProtoReflect.Descriptor instead.

func (*WorkflowNode) GetLaunchplanRef 

func (x *WorkflowNode) GetLaunchplanRef() *Identifier

func (*WorkflowNode) GetReference 

func (m *WorkflowNode) GetReference() isWorkflowNode_Reference

func (*WorkflowNode) GetSubWorkflowRef 

func (x *WorkflowNode) GetSubWorkflowRef() *Identifier

func (*WorkflowNode) ProtoMessage 

func (*WorkflowNode) ProtoMessage()

func (*WorkflowNode) ProtoReflect added in v1.10.7 

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

func (*WorkflowNode) Reset 

func (x *WorkflowNode) Reset()

func (*WorkflowNode) String 

func (x *WorkflowNode) String() string

type WorkflowNode_LaunchplanRef 

type WorkflowNode_LaunchplanRef struct {
	// A globally unique identifier for the launch plan.
	LaunchplanRef *Identifier `protobuf:"bytes,1,opt,name=launchplan_ref,json=launchplanRef,proto3,oneof"`
}

type WorkflowNode_SubWorkflowRef 

type WorkflowNode_SubWorkflowRef struct {
	// Reference to a subworkflow, that should be defined with the compiler context
	SubWorkflowRef *Identifier `protobuf:"bytes,2,opt,name=sub_workflow_ref,json=subWorkflowRef,proto3,oneof"`
}

type WorkflowTemplate 

type WorkflowTemplate struct {

	// A globally unique identifier for the workflow.
	Id *Identifier `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Extra metadata about the workflow.
	Metadata *WorkflowMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// Defines a strongly typed interface for the Workflow. This can include some optional parameters.
	Interface *TypedInterface `protobuf:"bytes,3,opt,name=interface,proto3" json:"interface,omitempty"`
	// A list of nodes. In addition, 'globals' is a special reserved node id that can be used to consume workflow inputs.
	Nodes []*Node `protobuf:"bytes,4,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// A list of output bindings that specify how to construct workflow outputs. Bindings can pull node outputs or
	// specify literals. All workflow outputs specified in the interface field must be bound in order for the workflow
	// to be validated. A workflow has an implicit dependency on all of its nodes to execute successfully in order to
	// bind final outputs.
	// Most of these outputs will be Binding's with a BindingData of type OutputReference.  That is, your workflow can
	// just have an output of some constant (`Output(5)`), but usually, the workflow will be pulling
	// outputs from the output of a task.
	Outputs []*Binding `protobuf:"bytes,5,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// +optional A catch-all node. This node is executed whenever the execution engine determines the workflow has failed.
	// The interface of this node must match the Workflow interface with an additional input named 'error' of type
	// pb.lyft.flyte.core.Error.
	FailureNode *Node `protobuf:"bytes,6,opt,name=failure_node,json=failureNode,proto3" json:"failure_node,omitempty"`
	// workflow defaults
	MetadataDefaults *WorkflowMetadataDefaults `protobuf:"bytes,7,opt,name=metadata_defaults,json=metadataDefaults,proto3" json:"metadata_defaults,omitempty"`
	// contains filtered or unexported fields
}

Flyte Workflow Structure that encapsulates task, branch and subworkflow nodes to form a statically analyzable, directed acyclic graph.

func (*WorkflowTemplate) Descriptor deprecated 

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

Deprecated: Use WorkflowTemplate.ProtoReflect.Descriptor instead.

func (*WorkflowTemplate) GetFailureNode 

func (x *WorkflowTemplate) GetFailureNode() *Node

func (*WorkflowTemplate) GetId 

func (x *WorkflowTemplate) GetId() *Identifier

func (*WorkflowTemplate) GetInterface 

func (x *WorkflowTemplate) GetInterface() *TypedInterface

func (*WorkflowTemplate) GetMetadata 

func (x *WorkflowTemplate) GetMetadata() *WorkflowMetadata

func (*WorkflowTemplate) GetMetadataDefaults 

func (x *WorkflowTemplate) GetMetadataDefaults() *WorkflowMetadataDefaults

func (*WorkflowTemplate) GetNodes 

func (x *WorkflowTemplate) GetNodes() []*Node

func (*WorkflowTemplate) GetOutputs 

func (x *WorkflowTemplate) GetOutputs() []*Binding

func (*WorkflowTemplate) ProtoMessage 

func (*WorkflowTemplate) ProtoMessage()

func (*WorkflowTemplate) ProtoReflect added in v1.10.7 

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

func (*WorkflowTemplate) Reset 

func (x *WorkflowTemplate) Reset()

func (*WorkflowTemplate) String 

func (x *WorkflowTemplate) 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.