Skip to content

Commit 6cd166f

Browse files
authored
Add Search Phase Result Processors to SearchPipelineInfo (opensearch-project#18400)
Signed-off-by: Owais <[email protected]>
1 parent 3c0813f commit 6cd166f

File tree

2 files changed

+13
-1
lines changed

2 files changed

+13
-1
lines changed

server/src/main/java/org/opensearch/search/pipeline/SearchPipelineService.java

Lines changed: 12 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -476,8 +476,19 @@ public SearchPipelineInfo info() {
476476
.stream()
477477
.map(ProcessorInfo::new)
478478
.collect(Collectors.toList());
479+
List<ProcessorInfo> phaseProcessorInfoList = phaseInjectorProcessorFactories.keySet()
480+
.stream()
481+
.map(ProcessorInfo::new)
482+
.collect(Collectors.toList());
479483
return new SearchPipelineInfo(
480-
Map.of(Pipeline.REQUEST_PROCESSORS_KEY, requestProcessorInfoList, Pipeline.RESPONSE_PROCESSORS_KEY, responseProcessorInfoList)
484+
Map.of(
485+
Pipeline.REQUEST_PROCESSORS_KEY,
486+
requestProcessorInfoList,
487+
Pipeline.RESPONSE_PROCESSORS_KEY,
488+
responseProcessorInfoList,
489+
Pipeline.PHASE_PROCESSORS_KEY,
490+
phaseProcessorInfoList
491+
)
481492
);
482493
}
483494

server/src/test/java/org/opensearch/search/pipeline/SearchPipelineServiceTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1068,6 +1068,7 @@ public void testInfo() {
10681068
SearchPipelineInfo info = searchPipelineService.info();
10691069
assertTrue(info.containsProcessor(Pipeline.REQUEST_PROCESSORS_KEY, "scale_request_size"));
10701070
assertTrue(info.containsProcessor(Pipeline.RESPONSE_PROCESSORS_KEY, "fixed_score"));
1071+
assertTrue(info.containsProcessor(Pipeline.PHASE_PROCESSORS_KEY, "max_score"));
10711072
}
10721073

10731074
public void testExceptionOnPipelineCreation() {

0 commit comments

Comments
 (0)