workflow

package

v0.5.20 Latest Latest Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/lyft/flytepropeller

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func NewExecutor(ctx context.Context, store *storage.DataStore, ...) (executors.Workflow, error)
type Status

Constants ¶

This section is empty.

Variables ¶

View Source

var StatusReady = Status{TransitionToPhase: v1alpha1.WorkflowPhaseReady}

View Source

var StatusRunning = Status{TransitionToPhase: v1alpha1.WorkflowPhaseRunning}

View Source

var StatusSucceeding = Status{TransitionToPhase: v1alpha1.WorkflowPhaseSucceeding}

View Source

var StatusSuccess = Status{TransitionToPhase: v1alpha1.WorkflowPhaseSuccess}

Functions ¶

func NewExecutor ¶

func NewExecutor(ctx context.Context, store *storage.DataStore, enQWorkflow v1alpha1.EnqueueWorkflow, eventSink events.EventSink, k8sEventRecorder record.EventRecorder, metadataPrefix string, nodeExecutor executors.Node, scope promutils.Scope) (executors.Workflow, error)

Types ¶

type Status ¶

type Status struct {
	TransitionToPhase v1alpha1.WorkflowPhase
	Err               *core.ExecutionError
}

func StatusFailed ¶

func StatusFailed(err *core.ExecutionError) Status

func StatusFailing ¶

func StatusFailing(err *core.ExecutionError) Status

func StatusFailureNode ¶ added in v0.2.43

func StatusFailureNode(originalErr *core.ExecutionError) Status

Source Files ¶

View all Source files

executor.go

Directories ¶

Path	Synopsis
errors

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