Merge pull request #16 from damonlau27/master

prefer remote worker
2020-04-22 10:51:39 +02:00 · 2020-04-22 10:51:39 +02:00 · 6a3320b113
commit 6a3320b113
parent 9230b22ea4 c1888035ac
1 changed files with 2 additions and 1 deletions
--- a/sched.go
+++ b/sched.go
@ -117,7 +117,8 @@ func (m *Manager) maybeSchedRequest(req *workerRequest) (*workerResponse, error)

 	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]
 		if !ok {
 			log.Warnf("requested worker %d is not in scheduler", id)