executor

Documentation

Overview

Package executor provides functionality to execute workflows defined as directed acyclic graphs (DAGs).

Index

• type Executor
  • func NewExecutor(store *run.Store) *Executor
  • func (e *Executor) Run(ctx context.Context, d *dag.DAG) error

Types

type Executor

type Executor struct {
	RunStore           *run.Store
	DefaultTaskTimeout time.Duration // Optional global timeout per task (0 = none)
}

Executor is responsible for executing workflows defined as DAGs.

func NewExecutor

func NewExecutor(store *run.Store) *Executor

NewExecutor is a creates a new Executor with the given RunStore.

func (*Executor) Run

func (e *Executor) Run(ctx context.Context, d *dag.DAG) error

Run executes the given DAG workflow.