This commit is contained in:
Renan DelValle 2017-03-14 07:02:52 +00:00 committed by GitHub
commit 5a04d1dc08
9 changed files with 1134 additions and 1028 deletions

View file

@ -181,7 +181,7 @@ func (r *realisClient) KillInstances(key *aurora.JobKey, instances ...int32) (*a
instanceIds[instId] = true
}
resp, err := r.client.KillTasks(key, instanceIds)
resp, err := r.client.KillTasks(key, instanceIds, "")
if err != nil {
return nil, errors.Wrap(err, "Error sending Kill command to Aurora Scheduler")
}
@ -198,7 +198,7 @@ func (r *realisClient) KillJob(key *aurora.JobKey) (*aurora.Response, error) {
}
if len(instanceIds) > 0 {
resp, err := r.client.KillTasks(key, instanceIds)
resp, err := r.client.KillTasks(key, instanceIds, "")
if err != nil {
return nil, errors.Wrap(err, "Error sending Kill command to Aurora Scheduler")