k8s

Documentation

Overview

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

Index

• Constants
• func BuildFlyteWorkflow(wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, ...) (*v1alpha1.FlyteWorkflow, error)
• func WorkflowIDAsString(id *core.Identifier) string
• func WorkflowNameFromID(id string) string

Constants

const ExecutionIDLabel = "execution-id"

const WorkflowNameLabel = "workflow-name"

Functions

func BuildFlyteWorkflow

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

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

func WorkflowIDAsString

func WorkflowIDAsString(id *core.Identifier) string

Note: Update WorkflowNameFromID for any change made to WorkflowIDAsString

func WorkflowNameFromID

func WorkflowNameFromID(id string) string