fix(core): Change fill executor capacity logic (#44)

spinnaker · Aug 16, 2018 · 84562f6 · 84562f6
1 parent c210bfb
commit 84562f6
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/keiko-core/src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt b/keiko-core/src/main/kotlin/com/netflix/spinnaker/q/QueueProcessor.kt
@@ -57,8 +57,7 @@ class QueueProcessor(
     ifEnabled {
       if (executor.hasCapacity()) {
         if (fillExecutorEachCycle) {
-          val availableCapacity = executor.availableCapacity()
-          availableCapacity.downTo(0).forEach {
+          while (executor.hasCapacity()) {
             pollOnce()
           }
         } else {