task

package
v0.2.50 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2020 License: Apache-2.0 Imports: 42 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 ToTaskExecutionEvent(taskExecID *core.TaskExecutionIdentifier, in io.InputFilePaths, out io.OutputFilePaths, info pluginCore.PhaseInfo) (*event.TaskExecutionEvent, error)

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 (f FutureFileReader) Cache(ctx context.Context, wf *v1alpha1.FlyteWorkflow) error

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 (f FutureFileReader) Read(ctx context.Context) (*core.DynamicJobSpec, error)

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 (t Handler) Handle(ctx context.Context, nCtx handler.NodeExecutionContext) (handler.Transition, error)

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 (r RemoteFileWorkflowStore) Exists(ctx context.Context, path storage.DataReference) (bool, error)

func (RemoteFileWorkflowStore) Get added in v0.1.13 

func (r RemoteFileWorkflowStore) Get(ctx context.Context, source storage.DataReference) (*v1alpha1.FlyteWorkflow, error)

func (RemoteFileWorkflowStore) Put added in v0.1.13 

func (r RemoteFileWorkflowStore) Put(ctx context.Context, wf *v1alpha1.FlyteWorkflow, target storage.DataReference) error

Source Files

View all Source files

Directories

Path Synopsis
datacatalog
datacatalog/mocks
config
mocks

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.