Method NewTask

exec/executor.go:101–106

NewTask create new task (from current context).

(p plan.Task)

// NewTask create new task (from current context).
func (m *JobExecutor) NewTask(p plan.Task) Task {
	if p.IsParallel() {
		return NewTaskParallel(m.Ctx)
	}
	return NewTaskSequential(m.Ctx)
}

// WalkPlan Main Entry point to take a Plan, and convert into Execution DAG
func (m *JobExecutor) WalkPlan(p plan.Task) (Task, error) {