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)
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 ¶ added in v0.1.16
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.