shared

package

v1.16.3 Latest Latest Go to latest Published: Dec 2, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flyteorg/flyte

Links

Open Source Insights

Documentation ¶

Overview ¶

Shared constants for the manager implementation.

Convenience methods for shared errors.

Index ¶

Constants
func GetInvalidArgumentError(field string) error
func GetMissingArgumentError(field string) error
type WorkflowExecutionConfigInterface

Constants ¶

View Source

const (
	Project               = "project"
	Domain                = "domain"
	Name                  = "name"
	ID                    = "id"
	Version               = "version"
	ResourceType          = "resource_type"
	Spec                  = "spec"
	Type                  = "type"
	RuntimeVersion        = "runtime version"
	Metadata              = "metadata"
	TypedInterface        = "typed interface"
	Image                 = "image"
	Limit                 = "limit"
	Filters               = "filters"
	ExpectedInputs        = "expected_inputs"
	FixedInputs           = "fixed_inputs"
	DefaultInputs         = "default_inputs"
	Inputs                = "inputs"
	State                 = "state"
	ExecutionID           = "execution_id"
	NodeID                = "node_id"
	NodeExecutionID       = "node_execution_id"
	TaskID                = "task_id"
	OccurredAt            = "occurred_at"
	Event                 = "event"
	ParentTaskExecutionID = "parent_task_execution_id"
	UserInputs            = "user_inputs"
	Attributes            = "attributes"
	MatchingAttributes    = "matching_attributes"
	// Parent of a node execution in the node executions table
	ParentID        = "parent_id"
	WorkflowClosure = "workflow_closure"
)

Field names for reference

Variables ¶

This section is empty.

Functions ¶

func GetInvalidArgumentError ¶

func GetInvalidArgumentError(field string) error

func GetMissingArgumentError ¶

func GetMissingArgumentError(field string) error

Types ¶

type WorkflowExecutionConfigInterface ¶

type WorkflowExecutionConfigInterface interface {
	// GetMaxParallelism Can be used to control the number of parallel nodes to run within the workflow. This is useful to achieve fairness.
	GetMaxParallelism() int32
	// GetRawOutputDataConfig Encapsulates user settings pertaining to offloaded data (i.e. Blobs, Schema, query data, etc.).
	GetRawOutputDataConfig() *admin.RawOutputDataConfig
	// GetSecurityContext Indicates security context permissions for executions triggered with this matchable attribute.
	GetSecurityContext() *core.SecurityContext
	// GetAnnotations Custom annotations to be applied to a triggered execution resource.
	GetAnnotations() *admin.Annotations
	// GetLabels Custom labels to be applied to a triggered execution resource.
	GetLabels() *admin.Labels
	// GetInterruptible indicates a workflow should be flagged as interruptible for a single execution. If omitted, the workflow's default is used.
	GetInterruptible() *wrappers.BoolValue
	// GetOverwriteCache indicates a workflow should skip all its cached results and re-compute its output, overwriting any already stored data.
	GetOverwriteCache() bool
	// GetEnvs defines environment variables to be set for the execution.
	GetEnvs() *admin.Envs
}

WorkflowExecutionConfigInterface is used as common interface for capturing the common behavior catering to the needs of fetching the WorkflowExecutionConfig across LaunchPlanSpec, ExecutionCreateRequest MatchableResource_WORKFLOW_EXECUTION_CONFIG and ApplicationConfig

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL