Setup this dag of tasks
()
| 375 | |
| 376 | // Setup this dag of tasks |
| 377 | func (m *JobExecutor) Setup() error { |
| 378 | if m == nil { |
| 379 | return fmt.Errorf("JobExecutor is nil?") |
| 380 | } |
| 381 | if m.RootTask == nil { |
| 382 | return fmt.Errorf("No task exists for this job") |
| 383 | } |
| 384 | return m.RootTask.Setup(0) |
| 385 | } |
| 386 | |
| 387 | // Run this task |
| 388 | func (m *JobExecutor) Run() error { |