operators

Documentation

Index

• type BashOperator
  • func (op *BashOperator) GetRegistryName() string
  • func (op *BashOperator) NewTask(name string, description string, dag *core.DAG, bash_command string) (core.TaskInterface, error)
  • func (op *BashOperator) Run()

Types

type BashOperator

type BashOperator struct {
	core.BaseTask
}

func (*BashOperator) GetRegistryName

func (op *BashOperator) GetRegistryName() string

func (*BashOperator) NewTask

func (op *BashOperator) NewTask(name string, description string, dag *core.DAG, bash_command string) (core.TaskInterface, error)

func (*BashOperator) Run

func (op *BashOperator) Run()