shared

package
v1.1.102 Latest Latest
Warning

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

Go to latest
Published: May 22, 2023 License: Apache-2.0 Imports: 6 Imported by: 4

Documentation

Overview

Shared constants for the manager implementation.

Convenience methods for shared errors.

Index

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

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

Jump to

Keyboard shortcuts

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