diff --git a/examples/client.go b/examples/client.go index 078ff8c..7cdfc82 100644 --- a/examples/client.go +++ b/examples/client.go @@ -316,7 +316,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) @@ -358,7 +363,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) @@ -406,7 +421,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 0907699..d66a4a2 100644 --- a/realis.go +++ b/realis.go @@ -208,7 +208,7 @@ func NewRealisClient(options ...option) (Realis, error) { fmt.Printf(" updating default backoff : %+v\n", *config.backoff) } - fmt.Printf("gorealis config: %+v\n", config) + fmt.Printf("gorealis config url: %+v\n", config.url) return &realisClient{ config: config, @@ -488,7 +488,7 @@ func (r *realisClient) ReestablishConn() error { fmt.Println(" r.config.url: ", r.config.url) return errors.New(" Missing Data for ReestablishConn ") } - fmt.Printf(" config before return: %+v\n", r.config) + fmt.Printf(" config url before return: %+v\n", r.config.url) return nil } @@ -934,7 +934,7 @@ func (r *realisClient) AddInstances(instKey aurora.InstanceKey, count int32) (*a return nil, errors.Wrap(err, "Error sending AddInstances command to Aurora Scheduler") } -//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 {