(task Task)
| 88 | } |
| 89 | |
| 90 | func (m *TaskParallel) Add(task Task) error { |
| 91 | if m.setup { |
| 92 | return fmt.Errorf("Cannot add task after Setup() called") |
| 93 | } |
| 94 | tr, ok := task.(TaskRunner) |
| 95 | if !ok { |
| 96 | panic(fmt.Sprintf("must be taskrunner %T", task)) |
| 97 | } |
| 98 | m.tasks = append(m.tasks, task) |
| 99 | m.runners = append(m.runners, tr) |
| 100 | return nil |
| 101 | } |
| 102 | |
| 103 | func (m *TaskParallel) Children() []Task { return m.tasks } |
| 104 |