executor

type AssetTimeoutError struct {
	AssetName string
	Timeout   time.Duration
}

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

	// InteractivePythonLogs passes child process stdout/stderr through verbatim
	// (preserving carriage returns, without the timestamp/task-name/">> " prefix)
	// so progress bars like tqdm can update in place. Only safe for a single
	// sequential worker writing to a real terminal.
	InteractivePythonLogs bool
}

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
}