task

package
v0.2.1 Latest Latest
Warning

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

Go to latest
Published: Jan 28, 2020 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source
const IDMaxLength = 50

Variables

View Source
var NoBarrierTransition = BarrierTransition{BarrierClockTick: 0}

Functions

func GetTaskExecutionIdentifier added in v0.1.13

func GetTaskExecutionIdentifier(nCtx handler.NodeExecutionContext) *core.TaskExecutionIdentifier

func ToTaskEventPhase added in v0.1.13

func ToTaskEventPhase(p pluginCore.Phase) core.TaskExecution_Phase

func ToTaskExecutionEvent added in v0.1.13

func ToTransitionType added in v0.1.13

func ToTransitionType(ttype pluginCore.TransitionType) handler.TransitionType

func WranglePluginsAndGenerateFinalList added in v0.1.13

func WranglePluginsAndGenerateFinalList(ctx context.Context, cfg *config.TaskPluginConfig, pr PluginRegistryIface) ([]core.PluginEntry, error)

Types

type BarrierKey added in v0.1.13

type BarrierKey = string

type BarrierTransition added in v0.1.13

type BarrierTransition struct {
	BarrierClockTick uint32
	CallLog          PluginCallLog
}

type CodecVersion added in v0.1.13

type CodecVersion uint8
const (
	GobCodecVersion CodecVersion = iota
)

type FutureFileReader added in v0.1.13

type FutureFileReader struct {
	RemoteFileWorkflowStore
	// contains filtered or unexported fields
}

func NewRemoteFutureFileReader added in v0.1.13

func NewRemoteFutureFileReader(ctx context.Context, dataDir storage.DataReference, store *storage.DataStore) (FutureFileReader, error)

func (FutureFileReader) Cache added in v0.1.13

func (FutureFileReader) CacheExists added in v0.1.13

func (f FutureFileReader) CacheExists(ctx context.Context) (bool, error)

func (FutureFileReader) Exists added in v0.1.13

func (f FutureFileReader) Exists(ctx context.Context) (bool, error)

func (FutureFileReader) Read added in v0.1.13

func (FutureFileReader) RetrieveCache added in v0.1.13

func (f FutureFileReader) RetrieveCache(ctx context.Context) (*v1alpha1.FlyteWorkflow, error)

type Handler added in v0.1.13

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

func New

func New(ctx context.Context, kubeClient executors.Client, client catalog.Client, scope promutils.Scope) (*Handler, error)

func (Handler) Abort added in v0.1.13

func (t Handler) Abort(ctx context.Context, nCtx handler.NodeExecutionContext, reason string) error

func (*Handler) CheckCatalogCache added in v0.1.13

func (t *Handler) CheckCatalogCache(ctx context.Context, tr pluginCore.TaskReader, inputReader io.InputReader, outputWriter io.OutputWriter) (bool, error)

func (Handler) Finalize added in v0.1.13

func (t Handler) Finalize(ctx context.Context, nCtx handler.NodeExecutionContext) error

func (*Handler) FinalizeRequired added in v0.1.13

func (t *Handler) FinalizeRequired() bool

func (Handler) Handle added in v0.1.13

func (Handler) ResolvePlugin added in v0.1.13

func (t Handler) ResolvePlugin(ctx context.Context, ttype string) (pluginCore.Plugin, error)

func (*Handler) Setup added in v0.1.13

func (t *Handler) Setup(ctx context.Context, sCtx handler.SetupContext) error

func (*Handler) ValidateOutputAndCacheAdd added in v0.1.13

func (t *Handler) ValidateOutputAndCacheAdd(ctx context.Context, nodeID v1alpha1.NodeID, i io.InputReader, r io.OutputReader,
	outputCommitter io.OutputWriter, tr pluginCore.TaskReader, m catalog.Metadata) (*io.ExecutionError, error)

type PluginCallLog added in v0.1.13

type PluginCallLog struct {
	PluginTransition *pluginRequestedTransition
}

type PluginRegistryIface added in v0.1.13

type PluginRegistryIface interface {
	GetCorePlugins() []pluginCore.PluginEntry
	GetK8sPlugins() []pluginK8s.PluginEntry
}

The plugin interface available especially for testing.

type RemoteFileWorkflowStore added in v0.1.13

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

func NewRemoteWorkflowStore added in v0.1.13

func NewRemoteWorkflowStore(store *storage.DataStore) RemoteFileWorkflowStore

func (RemoteFileWorkflowStore) Exists added in v0.1.13

func (RemoteFileWorkflowStore) Get added in v0.1.13

func (RemoteFileWorkflowStore) Put added in v0.1.13

Jump to

Keyboard shortcuts

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