File tree 1 file changed +16
-1
lines changed
1 file changed +16
-1
lines changed Original file line number Diff line number Diff line change 8
8
IProcessorConfig ,
9
9
IngestPipelineConfig ,
10
10
PROCESSOR_CONTEXT ,
11
+ PROCESSOR_TYPE ,
11
12
SearchPipelineConfig ,
12
13
WorkflowConfig ,
13
14
WorkflowFormValues ,
@@ -83,8 +84,17 @@ export function formikToPartialPipeline(
83
84
requestProcessors ,
84
85
context
85
86
) ,
87
+ // for search response, we need to explicitly separate out any phase results processors
88
+ phase_results_processors : processorConfigsToTemplateProcessors (
89
+ precedingProcessors . filter ( ( processor ) =>
90
+ isPhaseResultsProcessor ( processor )
91
+ ) ,
92
+ context
93
+ ) ,
86
94
response_processors : processorConfigsToTemplateProcessors (
87
- precedingProcessors ,
95
+ precedingProcessors . filter (
96
+ ( processor ) => ! isPhaseResultsProcessor ( processor )
97
+ ) ,
88
98
context
89
99
) ,
90
100
} as SearchPipelineConfig )
@@ -113,3 +123,8 @@ function getPrecedingProcessors(
113
123
} ) ;
114
124
return precedingProcessors ;
115
125
}
126
+
127
+ // currently the only phase results processor supported is the normalization processor
128
+ function isPhaseResultsProcessor ( processor : IProcessorConfig ) : boolean {
129
+ return processor . type === PROCESSOR_TYPE . NORMALIZATION ;
130
+ }
You can’t perform that action at this time.
0 commit comments