(p plan.Task)
| 266 | return NewJoinKey(m.Ctx, p), nil |
| 267 | } |
| 268 | func (m *JobExecutor) WalkPlanAll(p plan.Task) (Task, error) { |
| 269 | root, err := m.WalkPlanTask(p) |
| 270 | if err != nil { |
| 271 | u.Errorf("all damn %v err=%v", p, err) |
| 272 | return nil, err |
| 273 | } |
| 274 | if len(p.Children()) > 0 { |
| 275 | dagRoot := m.NewTask(p) |
| 276 | //u.Debugf("sequential?%v parallel?%v", p.IsSequential(), p.IsParallel()) |
| 277 | err = dagRoot.Add(root) |
| 278 | if err != nil { |
| 279 | u.Errorf("Could not add root: %v", err) |
| 280 | return nil, err |
| 281 | } |
| 282 | return dagRoot, m.WalkChildren(p, dagRoot) |
| 283 | } |
| 284 | return root, m.WalkChildren(p, root) |
| 285 | } |
| 286 | func (m *JobExecutor) WalkPlanTask(p plan.Task) (Task, error) { |
| 287 | //u.Debugf("WalkPlanTask: %p %T", p, p) |
| 288 | switch p := p.(type) { |
no test coverage detected