File tree Expand file tree Collapse file tree 2 files changed +12
-5
lines changed
packages/compass-aggregations/src Expand file tree Collapse file tree 2 files changed +12
-5
lines changed Original file line number Diff line number Diff line change @@ -107,9 +107,7 @@ export const StageOperatorSelect = ({
107107 [ onChange , index ]
108108 ) ;
109109
110- const enableAtlasSearchIndexes = usePreference ( 'enableAtlasSearchIndexes' ) ;
111110 const versionIncompatibleCompass =
112- enableAtlasSearchIndexes &&
113111 ! VIEW_PIPELINE_UTILS . isVersionSearchCompatibleForViewsCompass (
114112 serverVersion
115113 ) ;
@@ -176,6 +174,7 @@ export default withPreferences(
176174 isTimeSeries : state . isTimeSeries ,
177175 sourceName : state . sourceName ,
178176 preferencesReadOnly : ownProps . readOnly ,
177+ enableAtlasSearchIndexes : usePreference ( 'enableAtlasSearchIndexes' ) ,
179178 } ) ;
180179 return {
181180 selectedStage : stage . stageOperator ,
Original file line number Diff line number Diff line change @@ -47,12 +47,14 @@ export const filterStageOperators = ({
4747 isTimeSeries,
4848 sourceName,
4949 preferencesReadOnly,
50+ enableAtlasSearchIndexes,
5051} : {
5152 serverVersion : string ;
5253 env : ServerEnvironment ;
5354 isTimeSeries : boolean ;
5455 sourceName : string | null ;
5556 preferencesReadOnly : boolean ;
57+ enableAtlasSearchIndexes : boolean ;
5658} ) : FilteredStageOperators => {
5759 const namespaceType = isTimeSeries
5860 ? TIME_SERIES
@@ -66,6 +68,7 @@ export const filterStageOperators = ({
6668 env,
6769 namespaceType,
6870 preferencesReadOnly,
71+ enableAtlasSearchIndexes,
6972 } ) ;
7073
7174 if ( FilteredStagesCache . has ( cacheKey ) ) {
@@ -85,9 +88,14 @@ export const filterStageOperators = ({
8588 [ env , ATLAS ]
8689 : env ,
8790 } ,
88- } ) . filter ( ( op ) => {
89- return disallowOutputStagesOnCompassReadonly ( op , preferencesReadOnly ) ;
90- } ) ;
91+ } )
92+ . filter ( ( op ) => {
93+ return disallowOutputStagesOnCompassReadonly ( op , preferencesReadOnly ) ;
94+ } )
95+ . filter ( ( op ) => {
96+ // if enableAtlasSearchIndexes is false, only allow non search stages
97+ return enableAtlasSearchIndexes || ! isSearchStage ( op . value ) ;
98+ } ) ;
9199
92100 FilteredStagesCache . set ( cacheKey , filteredStages ) ;
93101
You can’t perform that action at this time.
0 commit comments