Skip to content

Commit

Permalink
Merge pull request #171 from ionutbalutoiu/optimize-wait-pool-running…
Browse files Browse the repository at this point in the history
…-idle-func

Optimize `waitPoolRunningIdleInstances` func
  • Loading branch information
gabriel-samfira authored Aug 25, 2023
2 parents 4f8ca60 + 93d290d commit d347979
Showing 1 changed file with 2 additions and 11 deletions.
13 changes: 2 additions & 11 deletions test/integration/e2e/instances.go
Original file line number Diff line number Diff line change
Expand Up @@ -69,9 +69,6 @@ func waitInstanceToBeRemoved(name string, timeout time.Duration) error {

func waitPoolRunningIdleInstances(poolID string, timeout time.Duration) error {
var timeWaited time.Duration = 0
var instances params.Instances
var poolInstances params.Instances
var err error

pool, err := getPool(cli, authToken, poolID)
if err != nil {
Expand All @@ -80,19 +77,13 @@ func waitPoolRunningIdleInstances(poolID string, timeout time.Duration) error {

log.Printf("Waiting for pool %s to have all instances as idle running", poolID)
for timeWaited < timeout {
instances, err = listInstances(cli, authToken)
poolInstances, err := listPoolInstances(cli, authToken, poolID)
if err != nil {
return err
}

poolInstances = make(params.Instances, 0)
runningIdleCount := 0
for _, instance := range instances {
if instance.PoolID != poolID {
continue
}
// current instance belongs to the pool we are waiting for
poolInstances = append(poolInstances, instance)
for _, instance := range poolInstances {
if instance.Status == commonParams.InstanceRunning && instance.RunnerStatus == params.RunnerIdle {
runningIdleCount++
}
Expand Down

0 comments on commit d347979

Please sign in to comment.