k8s

package
v1.1.28 Latest Latest
Warning

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

Go to latest
Published: Aug 17, 2022 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Overview

This package converts the output of the compiler into a K8s resource for propeller to execute.

Index

Constants

View Source
const (

	// The FlyteWorkflow domain according to registration ownership
	DomainLabel = "domain"
	// A concatenation of project, domain, workflow name, and a unique ID
	ExecutionIDLabel = "execution-id"
	// The FlyteWorkflow project according to registration ownership
	ProjectLabel = "project"
	// Shard keys are used during FlytePropeller sharding, this value is set to a hash of the FlyteWorkflow ExecutionID.
	// The pseudo-random unique ID component means this value is deterministic for the same ExecutionID, but will vary
	// across executions of the same workflow.
	ShardKeyLabel = "shard-key"
	// The fully qualified FlyteWorkflow name
	WorkflowNameLabel = "workflow-name"
)

Variables

This section is empty.

Functions

func BuildFlyteWorkflow

func BuildFlyteWorkflow(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap,
	executionID *core.WorkflowExecutionIdentifier, namespace string) (*v1alpha1.FlyteWorkflow, error)

BuildFlyteWorkflow builds v1alpha1.FlyteWorkflow resource. Returned error, if not nil, is of type errors.CompilerErrors.

func StripInterfaceTypeMetadata added in v1.1.4

func StripInterfaceTypeMetadata(iface *core.TypedInterface) *core.TypedInterface

func StripTypeMetadata added in v1.1.4

func StripTypeMetadata(t *core.LiteralType) *core.LiteralType

StripTypeMetadata strips the type metadata from the given type.

func WorkflowIDAsString

func WorkflowIDAsString(id *core.Identifier) string

Note: Update WorkflowNameFromID for any change made to WorkflowIDAsString

func WorkflowNameFromID added in v0.1.16

func WorkflowNameFromID(id string) string

Types

type WfClosureCrdFields added in v1.1.27

type WfClosureCrdFields struct {
	*v1alpha1.WorkflowSpec `json:"spec"`
	SubWorkflows           map[v1alpha1.WorkflowID]*v1alpha1.WorkflowSpec `json:"subWorkflows,omitempty"`
	Tasks                  map[v1alpha1.TaskID]*v1alpha1.TaskSpec         `json:"tasks"`
}

func BuildWfClosureCrdFields added in v1.1.27

func BuildWfClosureCrdFields(wfClosure *core.CompiledWorkflowClosure) (*WfClosureCrdFields, error)

Jump to

Keyboard shortcuts

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