scheduler: add err check for procurement

2015-10-20 11:53:41 -07:00
parent eee551c451
commit 9bbfc35fa9
1 changed files with 5 additions and 1 deletions
--- a/contrib/mesos/pkg/scheduler/plugin.go
+++ b/contrib/mesos/pkg/scheduler/plugin.go
@@ -341,7 +341,11 @@ func (k *kubeScheduler) doSchedule(task *podtask.T, err error) (string, error) {
 		}

 		task.Offer = offer
-		k.api.algorithm().Procurement()(task, details) // TODO(jdef) why is nothing checking the error returned here?
+		if err := k.api.algorithm().Procurement()(task, details); err != nil {
+			offer.Release()
+			task.Reset()
+			return "", err
+		}

 		if err := k.api.tasks().Update(task); err != nil {
 			offer.Release()