impl

package
v1.1.67 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2022 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCompiler

func NewCompiler() interfaces.Compiler

func NewFlyteWorkflowBuilder added in v0.6.56

func NewFlyteWorkflowBuilder(scope promutils.Scope) interfaces.FlyteWorkflowBuilder

func NewLaunchPlanInterfaceProvider

func NewLaunchPlanInterfaceProvider(launchPlan models.LaunchPlan, identifier core.Identifier) (common.InterfaceProvider, error)

func PrepareFlyteWorkflow added in v0.6.56

func PrepareFlyteWorkflow(data interfaces.ExecutionData, flyteWorkflow *v1alpha1.FlyteWorkflow) error

Types

type InterfaceProvider

type InterfaceProvider = common.InterfaceProvider

type K8sWorkflowExecutor added in v0.6.56

type K8sWorkflowExecutor struct {
	// contains filtered or unexported fields
}

K8sWorkflowExecutor directly creates and delete Flyte workflow execution CRD objects using the configured execution cluster interface.

func NewK8sWorkflowExecutor added in v0.6.56

func NewK8sWorkflowExecutor(config runtimeInterfaces.Configuration, executionCluster execClusterInterfaces.ClusterInterface, workflowBuilder interfaces.FlyteWorkflowBuilder, client *storage.DataStore) *K8sWorkflowExecutor

func (K8sWorkflowExecutor) Abort added in v0.6.56

func (K8sWorkflowExecutor) Execute added in v0.6.56

func (K8sWorkflowExecutor) ID added in v0.6.56

func (e K8sWorkflowExecutor) ID() string

type LaunchPlanInterfaceProvider

type LaunchPlanInterfaceProvider struct {
	// contains filtered or unexported fields
}

func (*LaunchPlanInterfaceProvider) GetExpectedInputs

func (p *LaunchPlanInterfaceProvider) GetExpectedInputs() *core.ParameterMap

func (*LaunchPlanInterfaceProvider) GetExpectedOutputs

func (p *LaunchPlanInterfaceProvider) GetExpectedOutputs() *core.VariableMap

func (*LaunchPlanInterfaceProvider) GetID

Jump to

Keyboard shortcuts

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