From 9bbfc35fa9f0ff4ddebf74ae956ffaf8ed91fd2e Mon Sep 17 00:00:00 2001 From: Sergiusz Urbaniak Date: Tue, 20 Oct 2015 11:53:41 -0700 Subject: [PATCH] scheduler: add err check for procurement --- contrib/mesos/pkg/scheduler/plugin.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/contrib/mesos/pkg/scheduler/plugin.go b/contrib/mesos/pkg/scheduler/plugin.go index 1c8d01eede7..37dedda7c6d 100644 --- 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()