shared

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

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

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