prefer remote worker

This commit is contained in:
damonlau27 2020-04-22 16:18:02 +08:00
parent e75536581a
commit c1888035ac

View File

@ -117,7 +117,8 @@ func (m *Manager) maybeSchedRequest(req *workerRequest) (*workerResponse, error)
tried := 0 tried := 0
for _, id := range req.accept { for i := len(req.accept) - 1; i >= 0; i-- {
id := req.accept[i]
w, ok := m.workers[id] w, ok := m.workers[id]
if !ok { if !ok {
log.Warnf("requested worker %d is not in scheduler", id) log.Warnf("requested worker %d is not in scheduler", id)