executor

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

type Config map[scheduler.TaskInstanceType]Operator

type FormattingOptions struct {
	DoNotLogTimestamp bool
	DoNotLogTaskName  bool
	NoColor           bool
	MinimalLogs       bool
	TUIMode           bool                                               // suppress Running/Finished lines; TUI handles display
	LogOnlyWriter     io.Writer                                          // in TUI mode, worker output goes here (log file) instead of os.Stdout
	OnTaskStart       func(scheduler.TaskInstance)                       // called when worker begins executing a task
	OnTaskEnd         func(scheduler.TaskInstance, error, time.Duration) // called when worker finishes a task
}

type NoOpOperator struct{}

type Operator interface {
	Run(ctx context.Context, ti scheduler.TaskInstance) error
}

type OperatorMap map[pipeline.AssetType]Operator

type Sequential struct {
	TaskTypeMap map[pipeline.AssetType]Config
}