fix(sql): Limit the number of returned buffered executions (#4069)

Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
spinnaker · Mar 3, 2021 · fa87edf · fa87edf
1 parent 5cba4b4
commit fa87edf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...main/kotlin/com/netflix/spinnaker/orca/sql/pipeline/persistence/SqlExecutionRepository.kt b/...main/kotlin/com/netflix/spinnaker/orca/sql/pipeline/persistence/SqlExecutionRepository.kt
@@ -565,7 +565,9 @@ class SqlExecutionRepository(
   }
 
   override fun retrieveBufferedExecutions(): MutableList<PipelineExecution> =
-    ExecutionCriteria().setStatuses(BUFFERED)
+    ExecutionCriteria()
+      .setPageSize(100)
+      .setStatuses(BUFFERED)
       .let { criteria ->
         rx.Observable.merge(
           retrieve(ORCHESTRATION, criteria, partitionName),