scheduler: add newlines for readibility in doSchedule
This commit is contained in:
@@ -325,16 +325,20 @@ func (k *kubeScheduler) doSchedule(task *podtask.T) (string, error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if offer == nil {
|
if offer == nil {
|
||||||
offer, err = k.api.algorithm().SchedulePod(k.api.offers(), k.api, task)
|
offer, err = k.api.algorithm().SchedulePod(k.api.offers(), k.api, task)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", err
|
return "", err
|
||||||
}
|
}
|
||||||
|
|
||||||
details := offer.Details()
|
details := offer.Details()
|
||||||
if details == nil {
|
if details == nil {
|
||||||
return "", fmt.Errorf("offer already invalid/expired for task %v", task.ID)
|
return "", fmt.Errorf("offer already invalid/expired for task %v", task.ID)
|
||||||
}
|
}
|
||||||
|
|
||||||
slaveId := details.GetSlaveId().GetValue()
|
slaveId := details.GetSlaveId().GetValue()
|
||||||
if slaveHostName := k.api.slaveHostNameFor(slaveId); slaveHostName == "" {
|
if slaveHostName := k.api.slaveHostNameFor(slaveId); slaveHostName == "" {
|
||||||
// not much sense in Release()ing the offer here since its owner died
|
// not much sense in Release()ing the offer here since its owner died
|
||||||
|
Reference in New Issue
Block a user