Documentation
¶
Index ¶
- Constants
- Variables
- func GetTaskExecutionIdentifier(nCtx handler.NodeExecutionContext) *core.TaskExecutionIdentifier
- func ToTaskEventPhase(p pluginCore.Phase) core.TaskExecution_Phase
- func ToTaskExecutionEvent(input ToTaskExecutionEventInputs) (*event.TaskExecutionEvent, error)
- func ToTransitionType(ttype pluginCore.TransitionType) handler.TransitionType
- func WranglePluginsAndGenerateFinalList(ctx context.Context, cfg *config.TaskPluginConfig, pr PluginRegistryIface) ([]core.PluginEntry, error)
- type BarrierKey
- type BarrierTransition
- type CodecVersion
- type FutureFileReader
- func (f FutureFileReader) Cache(ctx context.Context, wf *v1alpha1.FlyteWorkflow) error
- func (f FutureFileReader) CacheExists(ctx context.Context) (bool, error)
- func (f FutureFileReader) Exists(ctx context.Context) (bool, error)
- func (f FutureFileReader) Read(ctx context.Context) (*core.DynamicJobSpec, error)
- func (f FutureFileReader) RetrieveCache(ctx context.Context) (*v1alpha1.FlyteWorkflow, error)
- type Handler
- func (t Handler) Abort(ctx context.Context, nCtx handler.NodeExecutionContext, reason string) error
- func (t *Handler) CheckCatalogCache(ctx context.Context, tr pluginCore.TaskReader, inputReader io.InputReader, ...) (catalog.Entry, error)
- func (t Handler) Finalize(ctx context.Context, nCtx handler.NodeExecutionContext) error
- func (t *Handler) FinalizeRequired() bool
- func (t Handler) Handle(ctx context.Context, nCtx handler.NodeExecutionContext) (handler.Transition, error)
- func (t Handler) ResolvePlugin(ctx context.Context, ttype string, executionConfig v1alpha1.ExecutionConfig) (pluginCore.Plugin, error)
- func (t *Handler) Setup(ctx context.Context, sCtx handler.SetupContext) error
- func (t *Handler) ValidateOutputAndCacheAdd(ctx context.Context, nodeID v1alpha1.NodeID, i io.InputReader, ...) (catalog.Status, *io.ExecutionError, error)
- type MetricKey
- type PluginCallLog
- type PluginRegistryIface
- type RemoteFileWorkflowStore
- func (r RemoteFileWorkflowStore) Exists(ctx context.Context, path storage.DataReference) (bool, error)
- func (r RemoteFileWorkflowStore) Get(ctx context.Context, source storage.DataReference) (*v1alpha1.FlyteWorkflow, error)
- func (r RemoteFileWorkflowStore) Put(ctx context.Context, wf *v1alpha1.FlyteWorkflow, target storage.DataReference) error
- type ToTaskExecutionEventInputs
Constants ¶
View Source
const DefaultMaxAttempts = 1
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(input ToTaskExecutionEventInputs) (*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 (*Handler) CheckCatalogCache ¶ added in v0.1.13
func (t *Handler) CheckCatalogCache(ctx context.Context, tr pluginCore.TaskReader, inputReader io.InputReader, outputWriter io.OutputWriter) (catalog.Entry, error)
func (*Handler) FinalizeRequired ¶ added in v0.1.13
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, executionConfig v1alpha1.ExecutionConfig) (pluginCore.Plugin, 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, executionConfig v1alpha1.ExecutionConfig, tr ioutils.SimpleTaskReader, m catalog.Metadata) (catalog.Status, *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
type ToTaskExecutionEventInputs ¶ added in v0.7.9
type ToTaskExecutionEventInputs struct { TaskExecContext pluginCore.TaskExecutionContext InputReader io.InputFilePaths OutputWriter io.OutputFilePaths Info pluginCore.PhaseInfo NodeExecutionMetadata handler.NodeExecutionMetadata ExecContext executors.ExecutionContext TaskType string PluginID string ResourcePoolInfo []*event.ResourcePoolInfo }
Source Files
¶
Click to show internal directories.
Click to hide internal directories.