Fixed pipeline aggregation registration.

Signed-off-by: AWSHurneyt <[email protected]>
AWSHurneyt · Jan 24, 2025 · 03c5f01 · 03c5f01
1 parent 03595f8
commit 03c5f01
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/alerting/src/main/kotlin/org/opensearch/alerting/AlertingPlugin.kt b/alerting/src/main/kotlin/org/opensearch/alerting/AlertingPlugin.kt
@@ -97,6 +97,7 @@ import org.opensearch.common.settings.SettingsFilter
 import org.opensearch.commons.alerting.action.AlertingActions
 import org.opensearch.commons.alerting.action.DocLevelMonitorFanOutAction
 import org.opensearch.commons.alerting.aggregation.bucketselectorext.BucketSelectorExtAggregationBuilder
+import org.opensearch.commons.alerting.aggregation.bucketselectorext.BucketSelectorIndices
 import org.opensearch.commons.alerting.model.BucketLevelTrigger
 import org.opensearch.commons.alerting.model.ChainedAlertTrigger
 import org.opensearch.commons.alerting.model.ClusterMetricsInput
@@ -459,10 +460,8 @@ internal class AlertingPlugin : PainlessExtension, ActionPlugin, ScriptPlugin, R
             SearchPlugin.PipelineAggregationSpec(
                 BucketSelectorExtAggregationBuilder.NAME,
                 { sin: StreamInput -> BucketSelectorExtAggregationBuilder(sin) },
-                { parser: XContentParser, agg_name: String ->
-                    BucketSelectorExtAggregationBuilder.parse(agg_name, parser)
-                }
-            )
+                { parser: XContentParser, agg_name: String -> BucketSelectorExtAggregationBuilder.parse(agg_name, parser) }
+            ).addResultReader({ sin: StreamInput -> BucketSelectorIndices(sin) })
         )
     }