Skip to content

Commit

Permalink
fix conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
colin-sentry committed Jan 16, 2025
1 parent 3cb1823 commit df4489e
Showing 1 changed file with 36 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1096,9 +1096,18 @@ def test_aggregation_filter_basic(self, setup_teardown: Any) -> None:
spans_storage = get_storage(StorageKey("eap_spans"))
msg_timestamp = BASE_TIME - timedelta(minutes=1)
messages = (
[gen_message(msg_timestamp, tags={"kylestag": "val1"}) for i in range(3)]
+ [gen_message(msg_timestamp, tags={"kylestag": "val2"}) for i in range(12)]
+ [gen_message(msg_timestamp, tags={"kylestag": "val3"}) for i in range(30)]
[
gen_span_message(msg_timestamp, tags={"kylestag": "val1"})
for i in range(3)
]
+ [
gen_span_message(msg_timestamp, tags={"kylestag": "val2"})
for i in range(12)
]
+ [
gen_span_message(msg_timestamp, tags={"kylestag": "val3"})
for i in range(30)
]
)
write_raw_unprocessed_events(spans_storage, messages) # type: ignore

Expand Down Expand Up @@ -1188,9 +1197,18 @@ def test_aggregation_filter_and_or(self, setup_teardown: Any) -> None:
spans_storage = get_storage(StorageKey("eap_spans"))
msg_timestamp = BASE_TIME - timedelta(minutes=1)
messages = (
[gen_message(msg_timestamp, tags={"kylestag": "val1"}) for i in range(3)]
+ [gen_message(msg_timestamp, tags={"kylestag": "val2"}) for i in range(12)]
+ [gen_message(msg_timestamp, tags={"kylestag": "val3"}) for i in range(30)]
[
gen_span_message(msg_timestamp, tags={"kylestag": "val1"})
for i in range(3)
]
+ [
gen_span_message(msg_timestamp, tags={"kylestag": "val2"})
for i in range(12)
]
+ [
gen_span_message(msg_timestamp, tags={"kylestag": "val3"})
for i in range(30)
]
)
write_raw_unprocessed_events(spans_storage, messages) # type: ignore

Expand Down Expand Up @@ -1353,9 +1371,18 @@ def test_bad_aggregation_filter(self, setup_teardown: Any) -> None:
spans_storage = get_storage(StorageKey("eap_spans"))
msg_timestamp = BASE_TIME - timedelta(minutes=1)
messages = (
[gen_message(msg_timestamp, tags={"kylestag": "val1"}) for i in range(3)]
+ [gen_message(msg_timestamp, tags={"kylestag": "val2"}) for i in range(12)]
+ [gen_message(msg_timestamp, tags={"kylestag": "val3"}) for i in range(30)]
[
gen_span_message(msg_timestamp, tags={"kylestag": "val1"})
for i in range(3)
]
+ [
gen_span_message(msg_timestamp, tags={"kylestag": "val2"})
for i in range(12)
]
+ [
gen_span_message(msg_timestamp, tags={"kylestag": "val3"})
for i in range(30)
]
)
write_raw_unprocessed_events(spans_storage, messages) # type: ignore

Expand Down

0 comments on commit df4489e

Please sign in to comment.