validators

Documentation

Overview

This package contains validators for all elements of the workflow spec (node, task, branch, interface, bindings... etc.)

Index

• func AreTypesCastable(upstreamType, downstreamType *flyte.LiteralType) bool
• func GetTagForType(x *core.LiteralType) string
• func IsOptionalType(variable flyte.Variable) bool
• func LiteralTypeForLiteral(l *core.Literal) *core.LiteralType
• func UnionDistinctVariableMaps(m1, m2 map[string]*core.Variable) (map[string]*core.Variable, error)
• func ValidateBindings(w c.WorkflowBuilder, node c.Node, bindings []*flyte.Binding, ...) (resolved *flyte.VariableMap, ok bool)
• func ValidateBooleanExpression(w c.WorkflowBuilder, node c.NodeBuilder, expr *flyte.BooleanExpression, ...) (ok bool)
• func ValidateBranchNode(w c.WorkflowBuilder, n c.NodeBuilder, requireParamType bool, ...) (discoveredNodes []c.NodeBuilder, ok bool)
• func ValidateInterface(nodeID c.NodeID, iface *core.TypedInterface, errs errors.CompileErrors) (typedInterface *core.TypedInterface, ok bool)
• func ValidateNode(w c.WorkflowBuilder, n c.NodeBuilder, validateConditionTypes bool, ...) (ok bool)
• func ValidateUnderlyingInterface(w c.WorkflowBuilder, node c.NodeBuilder, errs errors.CompileErrors) (iface *core.TypedInterface, ok bool)

Functions

func AreTypesCastable

func AreTypesCastable(upstreamType, downstreamType *flyte.LiteralType) bool

func GetTagForType

func GetTagForType(x *core.LiteralType) string

func IsOptionalType

func IsOptionalType(variable flyte.Variable) bool

IsOptionalType Return true if there is a None type in Union Type

func LiteralTypeForLiteral

func LiteralTypeForLiteral(l *core.Literal) *core.LiteralType

LiteralTypeForLiteral gets LiteralType for literal, nil if the value of literal is unknown, or type collection/map of type None if the literal is a non-homogeneous type.

func UnionDistinctVariableMaps

func UnionDistinctVariableMaps(m1, m2 map[string]*core.Variable) (map[string]*core.Variable, error)

func ValidateBindings

func ValidateBindings(w c.WorkflowBuilder, node c.Node, bindings []*flyte.Binding, params *flyte.VariableMap,
	validateParamTypes bool, edgeDirection c.EdgeDirection, errs errors.CompileErrors) (resolved *flyte.VariableMap, ok bool)

func ValidateBooleanExpression

func ValidateBooleanExpression(w c.WorkflowBuilder, node c.NodeBuilder, expr *flyte.BooleanExpression, requireParamType bool, errs errors.CompileErrors) (ok bool)

func ValidateBranchNode

func ValidateBranchNode(w c.WorkflowBuilder, n c.NodeBuilder, requireParamType bool, errs errors.CompileErrors) (
	discoveredNodes []c.NodeBuilder, ok bool)

func ValidateInterface

func ValidateInterface(nodeID c.NodeID, iface *core.TypedInterface, errs errors.CompileErrors) (
	typedInterface *core.TypedInterface, ok bool)

ValidateInterface validates interface has its required attributes set

func ValidateNode

func ValidateNode(w c.WorkflowBuilder, n c.NodeBuilder, validateConditionTypes bool, errs errors.CompileErrors) (ok bool)

func ValidateUnderlyingInterface

func ValidateUnderlyingInterface(w c.WorkflowBuilder, node c.NodeBuilder, errs errors.CompileErrors) (iface *core.TypedInterface, ok bool)

ValidateUnderlyingInterface validates the underlying interface of a node and returns the effective Typed Interface.