tasks

Documentation

Index

• Variables
• func DbtConverter(taskCtx plugin.SubTaskContext) (err errors.Error)
• func Git(taskCtx plugin.SubTaskContext) errors.Error
• type DbtOptions
• type DbtTaskData

Variables

var DbtConverterMeta = plugin.SubTaskMeta{
	Name:             "DbtConverter",
	EntryPoint:       DbtConverter,
	EnabledByDefault: true,
	Description:      "Convert data by dbt",
}

var GitMeta = plugin.SubTaskMeta{
	Name:             "Git",
	EntryPoint:       Git,
	EnabledByDefault: true,
	Description:      "Clone dbt project from git",
}

Functions

func DbtConverter

func DbtConverter(taskCtx plugin.SubTaskContext) (err errors.Error)

func Git

func Git(taskCtx plugin.SubTaskContext) errors.Error

Types

type DbtOptions

type DbtOptions struct {
	ProjectPath   string `json:"projectPath"`
	ProjectName   string `json:"projectName"`
	ProjectTarget string `json:"projectTarget"`
	// clone from git to projectPath if projectGitURL is not empty
	ProjectGitURL  string                 `json:"projectGitURL"`
	ProjectVars    map[string]interface{} `json:"projectVars"`
	SelectedModels []string               `json:"selectedModels"`
	FailFast       bool                   `json:"failFast"`
	ProfilesPath   string                 `json:"profilesPath"`
	Profile        string                 `json:"profile"`
	Threads        int                    `json:"threads"`
	NoVersionCheck bool                   `json:"noVersionCheck"`
	ExcludeModels  []string               `json:"excludeModels"`
	Selector       string                 `json:"selector"`
	State          string                 `json:"state"`
	Defer          bool                   `json:"defer"`
	NoDefer        bool                   `json:"noDefer"`
	FullRefresh    bool                   `json:"fullRefresh"`
	// deprecated, dbt run args
	Args  []string `json:"args"`
	Tasks []string `json:"tasks,omitempty"`
}

type DbtTaskData

type DbtTaskData struct {
	Options *DbtOptions
}