|
4 | 4 | import orjson |
5 | 5 | import pytest |
6 | 6 | from sentry_protos.snuba.v1.request_common_pb2 import TraceItemType |
7 | | -from sentry_protos.snuba.v1.trace_item_attribute_pb2 import ( |
8 | | - ExtrapolationMode as RPCExtrapolationMode, |
9 | | -) |
10 | 7 | from sentry_protos.snuba.v1.trace_item_attribute_pb2 import Function |
11 | 8 | from sentry_protos.snuba.v1.trace_item_filter_pb2 import ComparisonFilter |
12 | 9 | from urllib3.response import HTTPResponse |
|
28 | 25 | StoreDataResponse, |
29 | 26 | ) |
30 | 27 | from sentry.snuba.dataset import Dataset |
31 | | -from sentry.snuba.models import ExtrapolationMode, SnubaQuery, SnubaQueryEventType |
| 28 | +from sentry.snuba.models import SnubaQuery, SnubaQueryEventType |
32 | 29 | from sentry.snuba.subscriptions import create_snuba_query, create_snuba_subscription |
33 | 30 | from sentry.testutils.cases import SnubaTestCase, TestCase |
34 | 31 | from sentry.testutils.helpers.features import with_feature |
@@ -163,7 +160,6 @@ def test_translate_alert_rule_simple_count(self, mock_create_rpc) -> None: |
163 | 160 | assert snuba_query.dataset == Dataset.EventsAnalyticsPlatform.value |
164 | 161 | assert snuba_query.aggregate == "count(span.duration)" |
165 | 162 | assert snuba_query.query == "(span.duration:>100) AND is_transaction:1" |
166 | | - assert snuba_query.extrapolation_mode == ExtrapolationMode.SERVER_WEIGHTED.value |
167 | 163 |
|
168 | 164 | event_types = list( |
169 | 165 | SnubaQueryEventType.objects.filter(snuba_query=snuba_query).values_list( |
@@ -205,10 +201,6 @@ def test_translate_alert_rule_simple_count(self, mock_create_rpc) -> None: |
205 | 201 | assert expression.aggregation.aggregate == Function.FUNCTION_COUNT |
206 | 202 | assert expression.aggregation.key.name == "sentry.project_id" |
207 | 203 | assert expression.aggregation.label == "count(span.duration)" |
208 | | - assert ( |
209 | | - expression.aggregation.extrapolation_mode |
210 | | - == RPCExtrapolationMode.EXTRAPOLATION_MODE_SAMPLE_WEIGHTED |
211 | | - ) |
212 | 204 | assert expression.label == "count(span.duration)" |
213 | 205 |
|
214 | 206 | assert len(rpc_time_series_request.group_by) == 0 |
@@ -264,7 +256,6 @@ def test_translate_alert_rule_p95(self, mock_create_rpc) -> None: |
264 | 256 | assert snuba_query.dataset == Dataset.EventsAnalyticsPlatform.value |
265 | 257 | assert snuba_query.aggregate == "p95(span.duration)" |
266 | 258 | assert snuba_query.query == "(transaction.method:GET) AND is_transaction:1" |
267 | | - assert snuba_query.extrapolation_mode == ExtrapolationMode.NONE.value |
268 | 259 |
|
269 | 260 | event_types = list( |
270 | 261 | SnubaQueryEventType.objects.filter(snuba_query=snuba_query).values_list( |
@@ -330,7 +321,6 @@ def test_translate_alert_rule_count_unique(self, mock_create_rpc) -> None: |
330 | 321 | assert snuba_query.dataset == Dataset.EventsAnalyticsPlatform.value |
331 | 322 | assert snuba_query.aggregate == "count_unique(user)" |
332 | 323 | assert snuba_query.query == "(transaction:/api/*) AND is_transaction:1" |
333 | | - assert snuba_query.extrapolation_mode == ExtrapolationMode.SERVER_WEIGHTED.value |
334 | 324 |
|
335 | 325 | assert mock_create_rpc.called |
336 | 326 | call_args = mock_create_rpc.call_args |
@@ -387,7 +377,6 @@ def test_translate_alert_rule_empty_query(self, mock_create_rpc) -> None: |
387 | 377 | assert snuba_query.dataset == Dataset.EventsAnalyticsPlatform.value |
388 | 378 | assert snuba_query.aggregate == "count(span.duration)" |
389 | 379 | assert snuba_query.query == "is_transaction:1" |
390 | | - assert snuba_query.extrapolation_mode == ExtrapolationMode.NONE.value |
391 | 380 |
|
392 | 381 | assert mock_create_rpc.called |
393 | 382 | call_args = mock_create_rpc.call_args |
|
0 commit comments