diff --git a/examples/client.go b/examples/client.go index 23a04a5..e90555b 100644 --- a/examples/client.go +++ b/examples/client.go @@ -282,7 +282,12 @@ func main() { } currInstances := int32(len(live)) fmt.Println("Current num of instances: ", currInstances) - resp, err := r.AddInstances(aurora.InstanceKey{job.JobKey(), 0}, numOfInstances) + var instId int32 + for k := range live{ + instId = k + break + } + resp, err := r.AddInstances(aurora.InstanceKey{job.JobKey(), instId}, numOfInstances) if err != nil { fmt.Println(err) os.Exit(1) @@ -324,7 +329,17 @@ func main() { break case "update": fmt.Println("Updating a job with with more RAM and to 5 instances") - taskConfig, err := r.FetchTaskConfig(aurora.InstanceKey{job.JobKey(), 0}) + live, err := r.GetInstanceIds(job.JobKey(), aurora.ACTIVE_STATES) + if err != nil { + fmt.Println(err) + os.Exit(1) + } + var instId int32 + for k := range live{ + instId = k + break + } + taskConfig, err := r.FetchTaskConfig(aurora.InstanceKey{job.JobKey(), instId}) if err != nil { fmt.Println(err) os.Exit(1) @@ -372,7 +387,17 @@ func main() { break case "taskConfig": fmt.Println("Getting job info") - config, err := r.FetchTaskConfig(aurora.InstanceKey{job.JobKey(), 0}) + live, err := r.GetInstanceIds(job.JobKey(), aurora.ACTIVE_STATES) + if err != nil { + fmt.Println(err) + os.Exit(1) + } + var instId int32 + for k := range live{ + instId = k + break + } + config, err := r.FetchTaskConfig(aurora.InstanceKey{job.JobKey(), instId}) if err != nil { fmt.Println(err) diff --git a/realis.go b/realis.go index 5bd1c0b..c069dc4 100644 --- a/realis.go +++ b/realis.go @@ -327,7 +327,7 @@ func (r *realisClient) AddInstances(instKey aurora.InstanceKey, count int32) (*a return response.ResponseCodeCheck(resp) } -//Scale down the number of instances under a job configuration using the configuratipn of a specific instance +//Scale down the number of instances under a job configuration using the configuration of a specific instance func (r *realisClient) RemoveInstances(key *aurora.JobKey, count int32) (*aurora.Response, error) { instanceIds, err := r.GetInstanceIds(key, aurora.ACTIVE_STATES) if err != nil {