File tree Expand file tree Collapse file tree 4 files changed +20
-17
lines changed Expand file tree Collapse file tree 4 files changed +20
-17
lines changed Original file line number Diff line number Diff line change @@ -518,11 +518,13 @@ def get_rpc_config():
518518 request .GET .get ("disableAggregateExtrapolation" , "0" ) == "1"
519519 )
520520
521- extrapolation_mode = request .GET .get ("extrapolationMode" , None )
522- if extrapolation_mode and extrapolation_mode not in EXTRAPOLATION_MODE_MAP :
523- raise InvalidSearchQuery (f"Unknown extrapolation mode: { extrapolation_mode } " )
524- elif extrapolation_mode :
525- extrapolation_mode = EXTRAPOLATION_MODE_MAP [extrapolation_mode ]
521+ requested_mode = request .GET .get ("extrapolationMode" , None )
522+ if requested_mode is not None and requested_mode not in EXTRAPOLATION_MODE_MAP :
523+ raise InvalidSearchQuery (f"Unknown extrapolation mode: { requested_mode } " )
524+
525+ extrapolation_mode = (
526+ EXTRAPOLATION_MODE_MAP [requested_mode ] if requested_mode else None
527+ )
526528
527529 if scoped_dataset == Spans :
528530 return SearchResolverConfig (
Original file line number Diff line number Diff line change @@ -245,12 +245,13 @@ def get_rpc_config():
245245 if scoped_dataset not in RPC_DATASETS :
246246 raise NotImplementedError
247247
248- extrapolation_mode = request .GET .get ("extrapolationMode" , None )
248+ requested_mode = request .GET .get ("extrapolationMode" , None )
249+ if requested_mode is not None and requested_mode not in EXTRAPOLATION_MODE_MAP :
250+ raise InvalidSearchQuery (f"Unknown extrapolation mode: { requested_mode } " )
249251
250- if extrapolation_mode and extrapolation_mode not in EXTRAPOLATION_MODE_MAP :
251- raise InvalidSearchQuery (f"Unknown extrapolation mode: { extrapolation_mode } " )
252- elif extrapolation_mode :
253- extrapolation_mode = EXTRAPOLATION_MODE_MAP [extrapolation_mode ]
252+ extrapolation_mode = (
253+ EXTRAPOLATION_MODE_MAP [requested_mode ] if requested_mode else None
254+ )
254255
255256 if scoped_dataset == TraceMetrics :
256257 # tracemetrics uses aggregate conditions
Original file line number Diff line number Diff line change @@ -224,11 +224,11 @@ def get_rpc_config():
224224 if dataset not in RPC_DATASETS :
225225 raise NotImplementedError
226226
227- extrapolation_mode = request .GET .get ("extrapolationMode" , None )
228- if extrapolation_mode and extrapolation_mode not in EXTRAPOLATION_MODE_MAP :
229- raise InvalidSearchQuery (f"Unknown extrapolation mode: { extrapolation_mode } " )
230- elif extrapolation_mode :
231- extrapolation_mode = EXTRAPOLATION_MODE_MAP [extrapolation_mode ]
227+ requested_mode = request .GET .get ("extrapolationMode" , None )
228+ if requested_mode is not None and requested_mode not in EXTRAPOLATION_MODE_MAP :
229+ raise InvalidSearchQuery (f"Unknown extrapolation mode: { requested_mode } " )
230+
231+ extrapolation_mode = EXTRAPOLATION_MODE_MAP [requested_mode ] if requested_mode else None
232232
233233 if dataset == TraceMetrics :
234234 # tracemetrics uses aggregate conditions
Original file line number Diff line number Diff line change @@ -202,7 +202,7 @@ class ResolvedAggregate(ResolvedFunction):
202202 # The internal rpc alias for this column
203203 internal_name : Function .ValueType
204204 # Whether to enable extrapolation
205- extrapolation_mode_override : ExtrapolationMode .ValueType | None = None
205+ extrapolation_mode : ExtrapolationMode .ValueType
206206 is_aggregate : bool = field (default = True , init = False )
207207 # Only for aggregates, we only support functions with 1 argument right now
208208 argument : AttributeKey | None = None
@@ -223,7 +223,7 @@ class ResolvedConditionalAggregate(ResolvedFunction):
223223 # The internal rpc alias for this column
224224 internal_name : Function .ValueType
225225 # Whether to enable extrapolation
226- extrapolation_mode_override : ExtrapolationMode .ValueType | None = None
226+ extrapolation_mode : ExtrapolationMode .ValueType
227227 # The condition to filter on
228228 filter : TraceItemFilter
229229 # The attribute to conditionally aggregate on
You can’t perform that action at this time.
0 commit comments