Merge pull request #3225 from filecoin-project/fix/sched-missing-worker

check that worker referenced by task is actually still there.
2020-08-22 22:16:32 +02:00
parent a236957538 54862be3ff
commit 4311c96a44
1 changed files with 6 additions and 1 deletions
@@ -295,7 +295,12 @@ func (sh *scheduler) trySched() {

 		task.indexHeap = sqi
 		for wnd, windowRequest := range sh.openWindows {
-			worker := sh.workers[windowRequest.worker]
+			worker, ok := sh.workers[windowRequest.worker]
+			if !ok {
+				log.Errorf("worker referenced by windowRequest not found (worker: %d)", windowRequest.worker)
+				// TODO: How to move forward here?
+				continue
+			}

 			// TODO: allow bigger windows
 			if !windows[wnd].allocated.canHandleRequest(needRes, windowRequest.worker, worker.info.Resources) {