workflow

type Context struct {
	JobPackages        []string
	TaskHistory        TaskHistoryReader
	WorkspaceSnapshots bool
	SuspendExecution   func(jobworkflow.JobContext, string, execution.Requirements) error
	StageNodeExecution func(execution.Requirements)
	jobworkflow.JobContext
	ops.ServiceDependencies2
}

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

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

type TaskHistoryReader interface {
	CachedTaskOutput(context.Context, jobdb.JobKey, string, int64, string) (jobdb.TaskData, error)
}