added type check for pipeline aggregator types in Transform initializ…

…ation (opensearch-project#1014) Signed-off-by: n-dohrmann <[email protected]> Co-authored-by: Joanne Wang <[email protected]>
Joshua152 · Dec 22, 2023 · 72af905 · 72af905
1 parent e9772f7
commit 72af905
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/kotlin/org/opensearch/indexmanagement/transform/model/Transform.kt b/src/main/kotlin/org/opensearch/indexmanagement/transform/model/Transform.kt
@@ -77,6 +77,9 @@ data class Transform(
         aggregations.aggregatorFactories.forEach {
             require(supportedAggregations.contains(it.type)) { "Unsupported aggregation [${it.type}]" }
         }
+        aggregations.pipelineAggregatorFactories.forEach {
+            require(supportedAggregations.contains(it.type)) { "Unsupported aggregation [${it.type}]" }
+        }
         when (jobSchedule) {
             is CronSchedule -> {
                 // Job scheduler already correctly throws errors for this