(tg *plan.TaskGroup)
| 50 | } |
| 51 | |
| 52 | func (s *Scheduler) findTaskGroupInputs(tg *plan.TaskGroup) (ret []resource.DataResource) { |
| 53 | firstTask := tg.Tasks[0] |
| 54 | for _, input := range firstTask.Inputs { |
| 55 | dataLocation, found := s.shardLocator.GetShardLocation(s.Option.ExecutableFileHash + "-" + input.Name()) |
| 56 | if !found { |
| 57 | // log.Printf("Strange2: %s not allocated yet.", input.Name()) |
| 58 | continue |
| 59 | } |
| 60 | ret = append(ret, resource.DataResource{ |
| 61 | Location: dataLocation, |
| 62 | DataSizeMB: 1, // TODO: read previous run's size |
| 63 | }) |
| 64 | } |
| 65 | return |
| 66 | } |
| 67 | |
| 68 | func Assign(leader string, request *resource.AllocationRequest) (*resource.AllocationResult, error) { |
| 69 | values := make(url.Values) |
no test coverage detected