the task should run on the destination dataset shard
(input *Dataset, output *Dataset)
| 60 | |
| 61 | // the task should run on the destination dataset shard |
| 62 | func (f *FlowContext) AddAllToOneStep(input *Dataset, output *Dataset) (step *Step) { |
| 63 | step = f.NewStep() |
| 64 | FromStepToDataset(step, output) |
| 65 | FromDatasetToStep(input, step) |
| 66 | |
| 67 | // setup the network |
| 68 | task := step.NewTask() |
| 69 | if output != nil { |
| 70 | FromTaskToDatasetShard(task, output.GetShards()[0]) |
| 71 | } |
| 72 | for _, shard := range input.GetShards() { |
| 73 | FromDatasetShardToTask(shard, task) |
| 74 | } |
| 75 | return |
| 76 | } |
| 77 | |
| 78 | // the task should run on the source dataset shard |
| 79 | // input is nil for initial source dataset |
no test coverage detected