Documentation
¶
Overview ¶
A task encapsulates the logic of iterating or using composites for either a job or a workflow.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrDisconnectedNode = errors.New("node expected by input doesn't exist")
View Source
var ErrEmptyWorkflows = errors.New("no workflows provided")
View Source
var ErrExecutorNotFound = errors.New("executor type not found")
View Source
var ErrJobNotFound = errors.New("job not found")
View Source
var ErrNoRootNodes = errors.New("no root nodes found, please check your config")
View Source
var ErrRenderingJob = errors.New("error rendering job")
View Source
var ErrWorkflowNoJobs = errors.New("workflow has no jobs")
View Source
var ErrWorkflowNotFound = errors.New("workflow not found")
Functions ¶
This section is empty.
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 ¶ added in v0.3.0
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
Source Files
Click to show internal directories.
Click to hide internal directories.