task

Documentation

Overview

A task encapsulates the logic of iterating or using composites for either a job or a workflow.

Index

• Variables
• type TaskFactory
  • func NewMockTaskFactory(persistence db.Persistence) TaskFactory
  • func NewTaskFactory(appContext cli.AppContext, execQueue queue.Queue, ...) (TaskFactory, error)

Variables

var ErrDisconnectedNode = errors.New("node expected by input doesn't exist")

var ErrEmptyWorkflows = errors.New("no workflows provided")

var ErrExecutorNotFound = errors.New("executor type not found")

var ErrJobNotFound = errors.New("job not found")

var ErrNoRootNodes = errors.New("no root nodes found, please check your config")

var ErrRenderingJob = errors.New("error rendering job")

var ErrWorkflowNoJobs = errors.New("workflow has no jobs")

var ErrWorkflowNotFound = errors.New("workflow not found")

Types

type TaskFactory

type TaskFactory interface {
	CreateTask(ctx context.Context, executionID uuid.UUID, cid string) ([]dag.Node[dag.IOSpec], error)
	JobNames() []string
	NodeNames() []string
	GetNode(step string) (config.Node, error)
	GetJob(name string) (config.Job, error)
}

func NewMockTaskFactory

func NewMockTaskFactory(persistence db.Persistence) TaskFactory

func NewTaskFactory

func NewTaskFactory(appContext cli.AppContext, execQueue queue.Queue, nodeFactory dag.NodeStore[dag.IOSpec]) (TaskFactory, error)

NewTaskFactory creates a factory that makes it easier to create tasks for the workers