Function NewTaskParallel

exec/task_parallel.go:32–38

(ctx *plan.Context)

}

func NewTaskParallel(ctx *plan.Context) *TaskParallel {
	return &TaskParallel{
		TaskBase: NewTaskBase(ctx),
		runners:  make([]TaskRunner, 0),
		tasks:    make([]Task, 0),
	}
}

func (m *TaskParallel) PrintDag(depth int) {