123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719 |
- from datetime import datetime, timedelta
- from unittest import mock
- from uuid import uuid4
- import pytest
- from django.urls import NoReverseMatch, reverse
- from sentry import options
- from sentry.testutils.cases import TraceTestCase
- from sentry.utils.samples import load_data
- from tests.snuba.api.endpoints.test_organization_events import OrganizationEventsEndpointTestBase
- class OrganizationEventsTraceEndpointBase(OrganizationEventsEndpointTestBase, TraceTestCase):
- url_name: str
- FEATURES = [
- "organizations:performance-view",
- "organizations:performance-file-io-main-thread-detector",
- "organizations:trace-view-load-more",
- "organizations:performance-slow-db-issue",
- ]
- def setUp(self):
- """
- Span structure:
- root
- gen1-0
- gen2-0
- gen3-0
- gen1-1
- gen2-1
- gen1-2
- gen2-2
- """
- super().setUp()
- options.set("performance.issues.all.problem-detection", 1.0)
- options.set("performance.issues.file_io_main_thread.problem-creation", 1.0)
- options.set("performance.issues.slow_db_query.problem-creation", 1.0)
- self.login_as(user=self.user)
- self.url = reverse(
- self.url_name,
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": self.trace_id,
- },
- )
- def load_trace(self):
- self.root_event = self.create_event(
- trace_id=self.trace_id,
- transaction="root",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": f"GET gen1-{i}",
- "span_id": root_span_id,
- "trace_id": self.trace_id,
- }
- for i, root_span_id in enumerate(self.root_span_ids)
- ],
- measurements={
- "lcp": 1000,
- "fcp": 750,
- "fid": 3.5,
- },
- parent_span_id=None,
- file_io_performance_issue=True,
- slow_db_performance_issue=True,
- project_id=self.project.id,
- milliseconds=3000,
- )
- # First Generation
- # TODO: temporary, this is until we deprecate using this endpoint without useSpans
- if isinstance(self, OrganizationEventsTraceEndpointTestUsingSpans):
- self.gen1_span_ids = ["0014" * 4, *(uuid4().hex[:16] for _ in range(2))]
- else:
- self.gen1_span_ids = [uuid4().hex[:16] for _ in range(3)]
- self.gen1_project = self.create_project(organization=self.organization)
- self.gen1_events = [
- self.create_event(
- trace_id=self.trace_id,
- transaction=f"/transaction/gen1-{i}",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": f"GET gen2-{i}",
- "span_id": gen1_span_id,
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=root_span_id,
- project_id=self.gen1_project.id,
- milliseconds=2000,
- )
- for i, (root_span_id, gen1_span_id) in enumerate(
- zip(self.root_span_ids, self.gen1_span_ids)
- )
- ]
- # Second Generation
- self.gen2_span_ids = [uuid4().hex[:16] for _ in range(3)]
- self.gen2_project = self.create_project(organization=self.organization)
- # Intentially pick a span id that starts with 0s
- self.gen2_span_id = "0011" * 4
- self.gen2_events = [
- self.create_event(
- trace_id=self.trace_id,
- transaction=f"/transaction/gen2-{i}",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": f"GET gen3-{i}" if i == 0 else f"SPAN gen3-{i}",
- "span_id": gen2_span_id,
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=gen1_span_id,
- span_id=self.gen2_span_id if i == 0 else None,
- project_id=self.gen2_project.id,
- milliseconds=1000,
- )
- for i, (gen1_span_id, gen2_span_id) in enumerate(
- zip(self.gen1_span_ids, self.gen2_span_ids)
- )
- ]
- # Third generation
- self.gen3_project = self.create_project(organization=self.organization)
- self.gen3_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/transaction/gen3-0",
- spans=[],
- project_id=self.gen3_project.id,
- parent_span_id=self.gen2_span_id,
- milliseconds=500,
- )
- class OrganizationEventsTraceLightEndpointTest(OrganizationEventsTraceEndpointBase):
- url_name = "sentry-api-0-organization-events-trace-light"
- def test_no_projects(self):
- user = self.create_user()
- org = self.create_organization(owner=user)
- self.login_as(user=user)
- url = reverse(
- self.url_name,
- kwargs={"organization_id_or_slug": org.slug, "trace_id": uuid4().hex},
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- url,
- format="json",
- )
- assert response.status_code == 404, response.content
- def test_bad_ids(self):
- # Fake event id
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"event_id": uuid4().hex},
- format="json",
- )
- assert response.status_code == 404, response.content
- # Invalid event id
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"event_id": "not-a-event"},
- format="json",
- )
- assert response.status_code == 400, response.content
- # Fake trace id
- self.url = reverse(
- "sentry-api-0-organization-events-trace-light",
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": uuid4().hex,
- },
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"event_id": "a" * 32},
- format="json",
- )
- assert response.status_code == 404, response.content
- # Invalid trace id
- with pytest.raises(NoReverseMatch):
- self.url = reverse(
- "sentry-api-0-organization-events-trace-light",
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": "not-a-trace",
- },
- )
- def test_no_roots(self):
- """Even when there's no root, we return the current event"""
- self.load_trace()
- no_root_trace = uuid4().hex
- parent_span_id = uuid4().hex[:16]
- no_root_event = self.create_event(
- trace_id=no_root_trace,
- transaction="/not_root/but_only_transaction",
- spans=[],
- parent_span_id=parent_span_id,
- project_id=self.project.id,
- )
- url = reverse(
- "sentry-api-0-organization-events-trace-light",
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": no_root_trace,
- },
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- url,
- data={"event_id": no_root_event.event_id},
- format="json",
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 1
- event = response.data["transactions"][0]
- # Basically know nothing about this event
- assert event["generation"] is None
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] == parent_span_id
- assert event["event_id"] == no_root_event.event_id
- def test_multiple_roots(self):
- self.load_trace()
- second_root = self.create_event(
- trace_id=self.trace_id,
- transaction="/second_root",
- spans=[],
- parent_span_id=None,
- project_id=self.project.id,
- )
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": second_root.event_id, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 1
- event = response.data["transactions"][0]
- assert event["generation"] == 0
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] is None
- def test_root_event(self):
- self.load_trace()
- root_event_id = self.root_event.event_id
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": root_event_id, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 4
- events = {item["event_id"]: item for item in response.data["transactions"]}
- assert root_event_id in events
- event = events[root_event_id]
- assert event["generation"] == 0
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] is None
- for i, child_event in enumerate(self.gen1_events):
- child_event_id = child_event.event_id
- assert child_event_id in events
- event = events[child_event_id]
- assert event["generation"] == 1
- assert event["parent_event_id"] == root_event_id
- assert event["parent_span_id"] == self.root_span_ids[i]
- def test_root_with_multiple_roots(self):
- self.load_trace()
- root_event_id = self.root_event.event_id
- self.create_event(
- trace_id=self.trace_id,
- transaction="/second_root",
- spans=[],
- parent_span_id=None,
- project_id=self.project.id,
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"event_id": self.root_event.event_id},
- format="json",
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 4
- events = {item["event_id"]: item for item in response.data["transactions"]}
- assert root_event_id in events
- event = events[root_event_id]
- assert event["generation"] == 0
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] is None
- for i, child_event in enumerate(self.gen1_events):
- child_event_id = child_event.event_id
- assert child_event_id in events
- event = events[child_event_id]
- assert event["generation"] == 1
- assert event["parent_event_id"] == root_event_id
- assert event["parent_span_id"] == self.root_span_ids[i]
- def test_direct_parent_with_children(self):
- self.load_trace()
- root_event_id = self.root_event.event_id
- current_event = self.gen1_events[0].event_id
- child_event_id = self.gen2_events[0].event_id
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": current_event, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 3
- events = {item["event_id"]: item for item in response.data["transactions"]}
- assert root_event_id in events
- event = events[root_event_id]
- assert event["generation"] == 0
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] is None
- assert current_event in events
- event = events[current_event]
- assert event["generation"] == 1
- assert event["parent_event_id"] == root_event_id
- assert event["parent_span_id"] == self.root_span_ids[0]
- assert child_event_id in events
- event = events[child_event_id]
- assert event["generation"] == 2
- assert event["parent_event_id"] == current_event
- assert event["parent_span_id"] == self.gen1_span_ids[0]
- def test_direct_parent_with_children_and_multiple_root(self):
- self.load_trace()
- root_event_id = self.root_event.event_id
- current_event = self.gen1_events[0].event_id
- child_event_id = self.gen2_events[0].event_id
- self.create_event(
- trace_id=self.trace_id,
- transaction="/second_root",
- spans=[],
- parent_span_id=None,
- project_id=self.project.id,
- )
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": current_event, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 3
- events = {item["event_id"]: item for item in response.data["transactions"]}
- assert root_event_id in events
- event = events[root_event_id]
- assert event["generation"] == 0
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] is None
- assert current_event in events
- event = events[current_event]
- assert event["generation"] == 1
- assert event["parent_event_id"] == root_event_id
- assert event["parent_span_id"] == self.root_span_ids[0]
- assert child_event_id in events
- event = events[child_event_id]
- assert event["generation"] == 2
- assert event["parent_event_id"] == current_event
- assert event["parent_span_id"] == self.gen1_span_ids[0]
- def test_second_generation_with_children(self):
- self.load_trace()
- current_event = self.gen2_events[0].event_id
- child_event_id = self.gen3_event.event_id
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": current_event, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 2
- events = {item["event_id"]: item for item in response.data["transactions"]}
- assert current_event in events
- event = events[current_event]
- # Parent/generation is unknown in this case
- assert event["generation"] is None
- assert event["parent_event_id"] is None
- # But we still know the parent_span
- assert event["parent_span_id"] == self.gen1_span_ids[0]
- assert child_event_id in events
- event = events[child_event_id]
- assert event["generation"] is None
- assert event["parent_event_id"] == current_event
- assert event["parent_span_id"] == self.gen2_span_id
- def test_third_generation_no_children(self):
- self.load_trace()
- current_event = self.gen3_event.event_id
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": current_event, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 1
- event = response.data["transactions"][0]
- assert event["generation"] is None
- # Parent is unknown in this case
- assert event["parent_event_id"] is None
- # But we still know the parent_span
- assert event["parent_span_id"] == self.gen2_span_id
- def test_sibling_transactions(self):
- """More than one transaction can share a parent_span_id"""
- self.load_trace()
- gen3_event_siblings = [
- self.create_event(
- trace_id=self.trace_id,
- transaction="/transaction/gen3-1",
- spans=[],
- project_id=self.create_project(organization=self.organization).id,
- parent_span_id=self.gen2_span_ids[1],
- milliseconds=500,
- ).event_id,
- self.create_event(
- trace_id=self.trace_id,
- transaction="/transaction/gen3-2",
- spans=[],
- project_id=self.create_project(organization=self.organization).id,
- parent_span_id=self.gen2_span_ids[1],
- milliseconds=1500,
- ).event_id,
- ]
- current_event = self.gen2_events[1].event_id
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": current_event, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assert len(response.data["transactions"]) == 3
- events = {item["event_id"]: item for item in response.data["transactions"]}
- for child_event_id in gen3_event_siblings:
- assert child_event_id in events
- event = events[child_event_id]
- assert event["generation"] is None
- assert event["parent_event_id"] == current_event
- assert event["parent_span_id"] == self.gen2_span_ids[1]
- def test_with_error_event(self):
- self.load_trace()
- root_event_id = self.root_event.event_id
- current_transaction_event = self.gen1_events[0].event_id
- start, _ = self.get_start_end_from_day_ago(1000)
- error_data = load_data(
- "javascript",
- timestamp=start,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": self.gen1_span_ids[0],
- }
- error_data["tags"] = [["transaction", "/transaction/gen1-0"]]
- error = self.store_event(error_data, project_id=self.gen1_project.id)
- def assertions(response):
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 3
- events = {item["event_id"]: item for item in response.data["transactions"]}
- assert root_event_id in events
- event = events[root_event_id]
- assert event["generation"] == 0
- assert event["parent_event_id"] is None
- assert event["parent_span_id"] is None
- assert len(event["errors"]) == 0
- assert current_transaction_event in events
- event = events[current_transaction_event]
- assert event["generation"] == 1
- assert event["parent_event_id"] == root_event_id
- assert event["parent_span_id"] == self.root_span_ids[0]
- assert len(event["errors"]) == 1
- assert event["errors"][0]["event_id"] == error.event_id
- assert event["errors"][0]["issue_id"] == error.group_id
- assert event["errors"][0]["message"] == error.search_message
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"event_id": error.event_id, "project": -1},
- format="json",
- )
- assertions(response)
- with self.feature(self.FEATURES):
- data: dict[str, str | int] = {"event_id": current_transaction_event, "project": -1}
- response = self.client.get(self.url, data=data, format="json")
- assertions(response)
- def assert_orphan_error_response(self, response, error, span_id):
- assert response.status_code == 200, response.content
- assert response.data["transactions"] == []
- assert len(response.data["orphan_errors"]) == 1
- assert {
- "event_id": error.event_id,
- "issue_id": error.group_id,
- "span": span_id,
- "project_id": self.project.id,
- "project_slug": self.project.slug,
- "level": "fatal",
- "title": error.title,
- "timestamp": datetime.fromisoformat(error.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error.search_message,
- } == response.data["orphan_errors"][0]
- def test_with_one_orphan_error(self):
- self.load_trace()
- span_id = uuid4().hex[:16]
- start, _ = self.get_start_end_from_day_ago(1000)
- error_data = load_data(
- "javascript",
- timestamp=start,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error_data["level"] = "fatal"
- error = self.store_event(error_data, project_id=self.project.id)
- with self.feature(
- [*self.FEATURES, "organizations:performance-tracing-without-performance"]
- ):
- response = self.client.get(
- self.url,
- data={"event_id": error.event_id, "project": -1},
- format="json",
- )
- self.assert_orphan_error_response(response, error, span_id)
- def test_with_multiple_orphan_errors(self):
- self.load_trace()
- span_id = uuid4().hex[:16]
- start, end = self.get_start_end_from_day_ago(1000)
- error_data = load_data(
- "javascript",
- timestamp=start,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error_data["level"] = "fatal"
- error = self.store_event(error_data, project_id=self.project.id)
- error_data1 = load_data(
- "javascript",
- timestamp=end,
- )
- error_data1["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error_data1["level"] = "warning"
- self.store_event(error_data1, project_id=self.project.id)
- with self.feature(
- [*self.FEATURES, "organizations:performance-tracing-without-performance"]
- ):
- response = self.client.get(
- self.url,
- data={"event_id": error.event_id, "project": -1},
- format="json",
- )
- self.assert_orphan_error_response(response, error, span_id)
- def test_with_unknown_event(self):
- with self.feature(
- [*self.FEATURES, "organizations:performance-tracing-without-performance"]
- ):
- response = self.client.get(
- self.url,
- data={"event_id": "766758c00ff54d8ab865369ecab53ae6", "project": "-1"},
- format="json",
- )
- assert response.status_code == 404
- class OrganizationEventsTraceEndpointTest(OrganizationEventsTraceEndpointBase):
- url_name = "sentry-api-0-organization-events-trace"
- check_generation = True
- def assert_event(self, result, event_data, message):
- assert result["transaction"] == event_data.transaction, message
- assert result["event_id"] == event_data.event_id
- assert result["start_timestamp"] == event_data.data["start_timestamp"]
- assert result["profile_id"] == event_data.data["contexts"]["profile"]["profile_id"]
- def assert_trace_data(self, root, gen2_no_children=True):
- """see the setUp docstring for an idea of what the response structure looks like"""
- self.assert_event(root, self.root_event, "root")
- assert root["parent_event_id"] is None
- assert root["parent_span_id"] is None
- if self.check_generation:
- assert root["generation"] == 0
- assert root["transaction.duration"] == 3000
- assert root["sdk_name"] == "sentry.test.sdk"
- assert len(root["children"]) == 3
- self.assert_performance_issues(root)
- for i, gen1 in enumerate(root["children"]):
- self.assert_event(gen1, self.gen1_events[i], f"gen1_{i}")
- assert gen1["parent_event_id"] == self.root_event.event_id
- assert gen1["parent_span_id"] == self.root_span_ids[i]
- if self.check_generation:
- assert gen1["generation"] == 1
- assert gen1["transaction.duration"] == 2000
- assert gen1["sdk_name"] == "sentry.test.sdk"
- assert len(gen1["children"]) == 1
- gen2 = gen1["children"][0]
- self.assert_event(gen2, self.gen2_events[i], f"gen2_{i}")
- assert gen2["parent_event_id"] == self.gen1_events[i].event_id
- assert gen2["parent_span_id"] == self.gen1_span_ids[i]
- if self.check_generation:
- assert gen2["generation"] == 2
- assert gen2["transaction.duration"] == 1000
- assert gen2["sdk_name"] == "sentry.test.sdk"
- # Only the first gen2 descendent has a child
- if i == 0:
- assert len(gen2["children"]) == 1
- gen3 = gen2["children"][0]
- self.assert_event(gen3, self.gen3_event, f"gen3_{i}")
- assert gen3["parent_event_id"] == self.gen2_events[i].event_id
- assert gen3["parent_span_id"] == self.gen2_span_id
- if self.check_generation:
- assert gen3["generation"] == 3
- assert gen3["transaction.duration"] == 500
- assert gen3["sdk_name"] == "sentry.test.sdk"
- assert len(gen3["children"]) == 0
- elif gen2_no_children:
- assert len(gen2["children"]) == 0
- def assert_performance_issues(self, root):
- """Broken in the non-spans endpoint, but we're not maintaining that anymore"""
- pass
- def client_get(self, data, url=None):
- if url is None:
- url = self.url
- return self.client.get(
- url,
- data,
- format="json",
- )
- def test_no_projects(self):
- user = self.create_user()
- org = self.create_organization(owner=user)
- self.login_as(user=user)
- url = reverse(
- self.url_name,
- kwargs={"organization_id_or_slug": org.slug, "trace_id": uuid4().hex},
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- url,
- format="json",
- )
- assert response.status_code == 404, response.content
- def test_simple(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- assert "measurements" not in trace_transaction
- def test_simple_with_limit(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1, "limit": 200},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- assert "measurements" not in trace_transaction
- def test_detailed_trace(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1, "detailed": 1},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- root = trace_transaction
- assert root["transaction.status"] == "ok"
- root_tags = {tag["key"]: tag["value"] for tag in root["tags"]}
- for [key, value] in self.root_event.tags:
- if not key.startswith("sentry:"):
- assert root_tags[key] == value, f"tags - {key}"
- else:
- assert root_tags[key[7:]] == value, f"tags - {key}"
- assert root["measurements"]["lcp"]["value"] == 1000
- assert root["measurements"]["fcp"]["value"] == 750
- def test_detailed_trace_with_bad_tags(self):
- """Basically test that we're actually using the event serializer's method for tags"""
- trace = uuid4().hex
- self.create_event(
- trace_id=trace,
- transaction="bad-tags",
- parent_span_id=None,
- spans=[],
- project_id=self.project.id,
- tags=[["somethinglong" * 250, "somethinglong" * 250]],
- milliseconds=3000,
- store_event_kwargs={"assert_no_errors": False},
- )
- url = reverse(
- self.url_name,
- kwargs={"organization_id_or_slug": self.project.organization.slug, "trace_id": trace},
- )
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1, "detailed": 1},
- url=url,
- )
- assert response.status_code == 200, response.content
- root = response.data["transactions"][0]
- assert root["transaction.status"] == "ok"
- assert {"key": None, "value": None} in root["tags"]
- def test_bad_span_loop(self):
- """Maliciously create a loop in the span structure
- Structure then becomes something like this:
- root
- gen1-0...
- gen1-1
- gen2-1
- gen3-1
- gen_2-1
- gen3-1...
- """
- self.load_trace()
- gen3_loop_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/transaction/gen3-1/loop",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": "GET gen2-1",
- "span_id": self.gen1_span_ids[1],
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=self.gen2_span_ids[1],
- project_id=self.project.id,
- )
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- # Should be the same as the simple testcase
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction, gen2_no_children=False)
- # The difference is that gen3-1 should exist with no children
- gen2_1 = trace_transaction["children"][1]["children"][0]
- assert len(gen2_1["children"]) == 1
- gen3_1 = gen2_1["children"][0]
- assert gen3_1["event_id"] == gen3_loop_event.event_id
- # We didn't even try to start the loop of spans
- assert len(gen3_1["children"]) == 0
- def test_bad_orphan_span_loop(self):
- """Maliciously create a loop in the span structure but for an orphan event"""
- root_span_id = uuid4().hex[:16]
- root_parent_span = uuid4().hex[:16]
- root_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/root/",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": "GET orphan_child",
- "span_id": root_span_id,
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=root_parent_span,
- project_id=self.project.id,
- milliseconds=3000,
- start_timestamp=self.day_ago - timedelta(minutes=1),
- )
- orphan_child = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/child/",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": "GET orphan_root",
- "span_id": root_parent_span,
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=root_span_id,
- project_id=self.project.id,
- milliseconds=300,
- )
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 1
- # There really isn't a right answer to which orphan is the "root" since this loops, but the current
- # implementation will make the older event the root
- root = response.data["transactions"][0]
- self.assert_event(root, root_event, "root")
- assert len(root["children"]) == 1
- child = root["children"][0]
- self.assert_event(child, orphan_child, "child")
- def test_multiple_roots(self):
- trace_id = uuid4().hex
- first_root = self.create_event(
- trace_id=trace_id,
- transaction="/first_root",
- spans=[],
- parent_span_id=None,
- project_id=self.project.id,
- milliseconds=500,
- )
- second_root = self.create_event(
- trace_id=trace_id,
- transaction="/second_root",
- spans=[],
- parent_span_id=None,
- project_id=self.project.id,
- milliseconds=1000,
- )
- self.url = reverse(
- self.url_name,
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": trace_id,
- },
- )
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 2
- self.assert_event(response.data["transactions"][0], first_root, "first_root")
- self.assert_event(response.data["transactions"][1], second_root, "second_root")
- def test_sibling_transactions(self):
- """More than one transaction can share a parent_span_id"""
- self.load_trace()
- gen3_event_siblings = [
- self.create_event(
- trace_id=self.trace_id,
- transaction="/transaction/gen3-1",
- spans=[],
- project_id=self.create_project(organization=self.organization).id,
- parent_span_id=self.gen2_span_ids[1],
- milliseconds=1000,
- ).event_id,
- self.create_event(
- trace_id=self.trace_id,
- transaction="/transaction/gen3-2",
- spans=[],
- project_id=self.create_project(organization=self.organization).id,
- parent_span_id=self.gen2_span_ids[1],
- milliseconds=2000,
- ).event_id,
- ]
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- # Should be the same as the simple testcase, but skip checking gen2 children
- self.assert_trace_data(response.data["transactions"][0], gen2_no_children=False)
- gen2_parent = response.data["transactions"][0]["children"][1]["children"][0]
- assert len(gen2_parent["children"]) == 2
- assert [child["event_id"] for child in gen2_parent["children"]] == gen3_event_siblings
- def test_with_orphan_siblings(self):
- self.load_trace()
- parent_span_id = uuid4().hex[:16]
- root_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/root",
- spans=[],
- # Some random id so its separated from the rest of the trace
- parent_span_id=parent_span_id,
- project_id=self.project.id,
- # Shorter duration means that this event happened first, and should be ordered first
- milliseconds=1000,
- )
- root_sibling_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/root-sibling",
- spans=[],
- parent_span_id=parent_span_id,
- project_id=self.project.id,
- milliseconds=2000,
- )
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 3
- # The first item of the response should be the main trace
- main, *orphans = response.data["transactions"]
- self.assert_trace_data(main)
- assert [root_event.event_id, root_sibling_event.event_id] == [
- orphan["event_id"] for orphan in orphans
- ]
- def test_with_orphan_trace(self):
- self.load_trace()
- orphan_span_ids = {
- key: uuid4().hex[:16]
- for key in ["root", "root_span", "child", "child_span", "grandchild", "grandchild_span"]
- }
- # Create the orphan transactions
- root_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/root",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": "GET gen1 orphan",
- "span_id": orphan_span_ids["root_span"],
- "trace_id": self.trace_id,
- }
- ],
- # Some random id so its separated from the rest of the trace
- parent_span_id=uuid4().hex[:16],
- span_id=orphan_span_ids["root"],
- project_id=self.project.id,
- milliseconds=3000,
- start_timestamp=self.day_ago - timedelta(minutes=1),
- )
- child_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/child1-0",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": "GET gen1 orphan",
- "span_id": orphan_span_ids["child_span"],
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=orphan_span_ids["root_span"],
- span_id=orphan_span_ids["child"],
- project_id=self.gen1_project.id,
- # Because the snuba query orders based is_root then timestamp, this causes grandchild1-0 to be added to
- # results first before child1-0
- milliseconds=2000,
- )
- grandchild_event = self.create_event(
- trace_id=self.trace_id,
- transaction="/orphan/grandchild1-0",
- spans=[
- {
- "same_process_as_parent": True,
- "op": "http",
- "description": "GET gen1 orphan",
- "span_id": orphan_span_ids["grandchild_span"],
- "trace_id": self.trace_id,
- }
- ],
- parent_span_id=orphan_span_ids["child_span"],
- span_id=orphan_span_ids["grandchild"],
- project_id=self.gen1_project.id,
- milliseconds=1000,
- )
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 2
- # The first item of the response should be the main trace
- main, orphans = response.data["transactions"]
- self.assert_trace_data(main)
- self.assert_event(orphans, root_event, "orphan-root")
- assert len(orphans["children"]) == 1
- if self.check_generation:
- assert orphans["generation"] == 0
- assert orphans["parent_event_id"] is None
- child = orphans["children"][0]
- self.assert_event(child, child_event, "orphan-child")
- assert len(child["children"]) == 1
- if self.check_generation:
- assert child["generation"] == 1
- assert child["parent_event_id"] == root_event.event_id
- grandchild = child["children"][0]
- self.assert_event(grandchild, grandchild_event, "orphan-grandchild")
- if self.check_generation:
- assert grandchild["generation"] == 2
- assert grandchild["parent_event_id"] == child_event.event_id
- def test_with_errors(self):
- self.load_trace()
- error, error1, _ = self.load_errors(self.gen1_project, self.gen1_span_ids[0])
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- self.assert_trace_data(response.data["transactions"][0])
- gen1_event = response.data["transactions"][0]["children"][0]
- assert len(gen1_event["errors"]) == 3
- data = {
- "event_id": error.event_id,
- "issue_id": error.group_id,
- "span": self.gen1_span_ids[0],
- "project_id": self.gen1_project.id,
- "project_slug": self.gen1_project.slug,
- "level": "fatal",
- "title": error.title,
- "timestamp": datetime.fromisoformat(error.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error.search_message,
- }
- data1 = {
- "event_id": error1.event_id,
- "issue_id": error1.group_id,
- "span": self.gen1_span_ids[0],
- "project_id": self.gen1_project.id,
- "project_slug": self.gen1_project.slug,
- "level": "warning",
- "title": error1.title,
- "timestamp": datetime.fromisoformat(error1.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error1.search_message,
- }
- assert data in gen1_event["errors"]
- assert data1 in gen1_event["errors"]
- def test_with_only_orphan_errors_with_same_span_ids(self):
- span_id = uuid4().hex[:16]
- start, end = self.get_start_end_from_day_ago(10000)
- # Error 1
- error_data = load_data(
- "javascript",
- timestamp=end,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error_data["level"] = "fatal"
- error = self.store_event(error_data, project_id=self.project.id)
- # Error 2 before after Error 1
- error_data1 = load_data(
- "javascript",
- timestamp=start,
- )
- error_data1["level"] = "warning"
- error_data1["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error1 = self.store_event(error_data1, project_id=self.project.id)
- with self.feature(
- [*self.FEATURES, "organizations:performance-tracing-without-performance"]
- ):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data) == 2
- # Sorting by timestamp puts Error1 after Error2 in the response
- assert {
- "event_id": error.event_id,
- "issue_id": error.group_id,
- "span": span_id,
- "project_id": self.project.id,
- "project_slug": self.project.slug,
- "level": "fatal",
- "title": error.title,
- "timestamp": datetime.fromisoformat(error.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error.search_message,
- } == response.data["orphan_errors"][1]
- assert {
- "event_id": error1.event_id,
- "issue_id": error1.group_id,
- "span": span_id,
- "project_id": self.project.id,
- "project_slug": self.project.slug,
- "level": "warning",
- "title": error1.title,
- "timestamp": datetime.fromisoformat(error1.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error1.search_message,
- } == response.data["orphan_errors"][0]
- def test_with_only_orphan_errors_with_different_span_ids(self):
- start, _ = self.get_start_end_from_day_ago(1000)
- span_id = uuid4().hex[:16]
- error_data = load_data(
- "javascript",
- timestamp=start,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error_data["level"] = "fatal"
- error = self.store_event(error_data, project_id=self.project.id)
- error_data["level"] = "warning"
- span_id1 = uuid4().hex[:16]
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id1,
- }
- error1 = self.store_event(error_data, project_id=self.project.id)
- with self.feature(
- [*self.FEATURES, "organizations:performance-tracing-without-performance"]
- ):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data["orphan_errors"]) == 2
- assert {
- "event_id": error.event_id,
- "issue_id": error.group_id,
- "span": span_id,
- "project_id": self.project.id,
- "project_slug": self.project.slug,
- "level": "fatal",
- "title": error.title,
- "timestamp": datetime.fromisoformat(error.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error.search_message,
- } in response.data["orphan_errors"]
- assert {
- "event_id": error1.event_id,
- "issue_id": error1.group_id,
- "span": span_id1,
- "project_id": self.project.id,
- "project_slug": self.project.slug,
- "level": "warning",
- "title": error1.title,
- "timestamp": datetime.fromisoformat(error1.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error1.search_message,
- } in response.data["orphan_errors"]
- def test_with_mixup_of_orphan_errors_with_simple_trace_data(self):
- self.load_trace()
- start, _ = self.get_start_end_from_day_ago(1000)
- span_id = uuid4().hex[:16]
- error_data = load_data(
- "javascript",
- timestamp=start,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id,
- }
- error_data["level"] = "fatal"
- error = self.store_event(error_data, project_id=self.project.id)
- error_data["level"] = "warning"
- span_id1 = uuid4().hex[:16]
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": span_id1,
- }
- with self.feature(
- [*self.FEATURES, "organizations:performance-tracing-without-performance"]
- ):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- assert len(response.data["transactions"]) == 1
- assert len(response.data["orphan_errors"]) == 1
- self.assert_trace_data(response.data["transactions"][0])
- assert {
- "event_id": error.event_id,
- "issue_id": error.group_id,
- "span": span_id,
- "project_id": self.project.id,
- "project_slug": self.project.slug,
- "level": "fatal",
- "title": error.title,
- "timestamp": datetime.fromisoformat(error.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": error.search_message,
- } in response.data["orphan_errors"]
- def test_with_default(self):
- self.load_trace()
- start, _ = self.get_start_end_from_day_ago(1000)
- default_event = self.load_default()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1},
- )
- assert response.status_code == 200, response.content
- self.assert_trace_data(response.data["transactions"][0])
- root_event = response.data["transactions"][0]
- assert len(root_event["errors"]) == 1
- assert {
- "event_id": default_event.event_id,
- "issue_id": default_event.group_id,
- "span": self.root_span_ids[0],
- "project_id": self.gen1_project.id,
- "project_slug": self.gen1_project.slug,
- "level": "debug",
- "title": "this is a log message",
- "timestamp": datetime.fromisoformat(default_event.timestamp).timestamp(),
- "generation": 0,
- "event_type": "error",
- "message": default_event.search_message,
- } in root_event["errors"]
- def test_pruning_root(self):
- self.load_trace()
- # Pruning shouldn't happen for the root event
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1, "event_id": self.root_event.event_id},
- )
- assert response.status_code == 200, response.content
- self.assert_trace_data(response.data["transactions"][0])
- def test_pruning_event(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"project": -1, "event_id": self.gen2_events[0].event_id},
- )
- assert response.status_code == 200, response.content
- root = response.data["transactions"][0]
- self.assert_event(root, self.root_event, "root")
- # Because of snuba query orders by timestamp we should still have all of the root's children
- assert len(root["children"]) == 3
- for i, gen1 in enumerate(root["children"]):
- self.assert_event(gen1, self.gen1_events[i], f"gen1_{i}")
- if i == 0:
- assert len(gen1["children"]) == 1
- gen2 = gen1["children"][0]
- self.assert_event(gen2, self.gen2_events[0], "gen2_0")
- assert len(gen2["children"]) == 1
- gen3 = gen2["children"][0]
- self.assert_event(gen3, self.gen3_event, "gen3_0")
- else:
- assert len(gen1["children"]) == 0
- @mock.patch("sentry.api.endpoints.organization_events_trace.query_trace_data")
- def test_timestamp_optimization(self, mock_query):
- """When timestamp is passed we'll ignore the statsPeriod and make a query with a smaller start & end"""
- self.load_trace()
- with self.feature(self.FEATURES):
- self.client_get(
- data={
- "project": -1,
- "timestamp": self.root_event.timestamp,
- "statsPeriod": "90d",
- },
- )
- mock_query.assert_called_once()
- params = mock_query.call_args.args[1]
- assert abs((params["end"] - params["start"]).days) <= 7
- def test_timestamp_optimization_without_mock(self):
- """Make sure that even if the params are smaller the query still works"""
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={
- "project": -1,
- "timestamp": self.root_event.timestamp,
- "statsPeriod": "90d",
- },
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- assert "measurements" not in trace_transaction
- class OrganizationEventsTraceEndpointTestUsingSpans(OrganizationEventsTraceEndpointTest):
- check_generation = False
- def client_get(self, data, url=None):
- data["useSpans"] = 1
- return super().client_get(data, url)
- def assert_performance_issues(self, root):
- assert len(root["performance_issues"]) == 2
- # The perf issues are the last 2 spans
- perf_issue_spans = {span["span_id"]: span for span in self.root_event.data["spans"][-2:]}
- for perf_issue in root["performance_issues"]:
- assert len(perf_issue["suspect_spans"]) == 1
- expected = perf_issue_spans[perf_issue["suspect_spans"][0]]
- assert perf_issue["start"] == expected["start_timestamp"]
- assert perf_issue["end"] == expected["timestamp"]
- @pytest.mark.querybuilder
- def test_simple(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- def test_simple_with_limit(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"limit": 200},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- def test_with_error_event(self):
- self.load_trace()
- start, _ = self.get_start_end_from_day_ago(1000)
- error_data = load_data(
- "javascript",
- timestamp=start,
- )
- error_data["contexts"]["trace"] = {
- "type": "trace",
- "trace_id": self.trace_id,
- "span_id": self.gen1_span_ids[0],
- }
- error_data["tags"] = [["transaction", "/transaction/gen1-0"]]
- error = self.store_event(error_data, project_id=self.gen1_project.id)
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- errors = trace_transaction["children"][0]["errors"]
- assert len(errors) == 1
- error_result = errors[0]
- assert error_result["event_id"] == error.event_id
- assert error_result["span"] == self.gen1_span_ids[0]
- assert error_result["title"] == error.title
- assert error_result["message"] == error.search_message
- @pytest.mark.skip(
- "Loops can only be orphans cause the most recent parent to be saved will overwrite the previous"
- )
- def test_bad_span_loop(self):
- super().test_bad_span_loop()
- @pytest.mark.skip("Can't use the detailed response with useSpans on")
- def test_detailed_trace_with_bad_tags(self):
- super().test_detailed_trace_with_bad_tags()
- @pytest.mark.skip("We shouldn't need to prune with events anymore since spans should be faster")
- def test_pruning_event(self):
- super().test_pruning_event()
- def test_detailed_trace(self):
- """Can't use detailed with useSpans, so this should actually just 400"""
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={"detailed": 1},
- )
- assert response.status_code == 400, response.content
- @mock.patch("sentry.api.endpoints.organization_events_trace.SpansIndexedQueryBuilder")
- def test_indexed_spans_only_query_required_projects(self, mock_query_builder):
- mock_builder = mock.Mock()
- mock_builder.resolve_column_name.return_value = "span_id"
- mock_builder.run_query.return_value = {}
- mock_query_builder.return_value = mock_builder
- # Add a few more projects to the org
- self.create_project(organization=self.organization)
- self.create_project(organization=self.organization)
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={},
- )
- assert sorted(
- [self.project.id, self.gen1_project.id, self.gen2_project.id, self.gen3_project.id]
- ) == sorted(mock_query_builder.mock_calls[0].args[1]["project_id"])
- assert sorted(
- [self.project.id, self.gen1_project.id, self.gen2_project.id, self.gen3_project.id]
- ) == sorted([p.id for p in mock_query_builder.mock_calls[0].args[1]["project_objects"]])
- assert response.status_code == 200, response.content
- def test_event_id(self):
- self.load_trace()
- # When given an event_id even if its not the root transaction we should prioritize loading that specific event
- # over loading roots
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={
- "timestamp": self.root_event.timestamp,
- # Limit of one means the only result is the target event
- "limit": 1,
- "eventId": self.gen1_events[0].event_id,
- },
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_event(trace_transaction, self.gen1_events[0], "root")
- def test_timestamp_optimization_without_mock(self):
- """Make sure that even if the params are smaller the query still works"""
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={
- "timestamp": self.root_event.timestamp,
- "statsPeriod": "90d",
- },
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- def test_measurements(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- root = trace_transaction
- assert root["measurements"]["lcp"]["value"] == 1000
- assert root["measurements"]["lcp"]["type"] == "duration"
- assert root["measurements"]["fid"]["value"] == 3.5
- assert root["measurements"]["fid"]["type"] == "duration"
- def test_project_param(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- # If project is included we should still return the entire trace
- response = self.client_get(
- data={"project": self.project.id},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- def test_split_by_char_optimization(self):
- self.load_trace()
- # This changes the span_id condition so its a split on a string instead of an array
- options.set("performance.traces.span_query_minimum_spans", 1)
- with self.feature(self.FEATURES):
- response = self.client_get(
- data={},
- )
- assert response.status_code == 200, response.content
- trace_transaction = response.data["transactions"][0]
- self.assert_trace_data(trace_transaction)
- # We shouldn't have detailed fields here
- assert "transaction.status" not in trace_transaction
- assert "tags" not in trace_transaction
- class OrganizationEventsTraceMetaEndpointTest(OrganizationEventsTraceEndpointBase):
- url_name = "sentry-api-0-organization-events-trace-meta"
- def test_no_projects(self):
- user = self.create_user()
- org = self.create_organization(owner=user)
- self.login_as(user=user)
- url = reverse(
- self.url_name,
- kwargs={"organization_id_or_slug": org.slug, "trace_id": uuid4().hex},
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- url,
- format="json",
- )
- assert response.status_code == 404, response.content
- def test_bad_ids(self):
- # Fake trace id
- self.url = reverse(
- self.url_name,
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": uuid4().hex,
- },
- )
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- format="json",
- )
- assert response.status_code == 200, response.content
- data = response.data
- assert data["projects"] == 0
- assert data["transactions"] == 0
- assert data["errors"] == 0
- assert data["performance_issues"] == 0
- # Invalid trace id
- with pytest.raises(NoReverseMatch):
- self.url = reverse(
- self.url_name,
- kwargs={
- "organization_id_or_slug": self.project.organization.slug,
- "trace_id": "not-a-trace",
- },
- )
- def test_simple(self):
- self.load_trace()
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"project": -1},
- format="json",
- )
- assert response.status_code == 200, response.content
- data = response.data
- assert data["projects"] == 4
- assert data["transactions"] == 8
- assert data["errors"] == 0
- assert data["performance_issues"] == 2
- def test_with_errors(self):
- self.load_trace()
- self.load_errors(self.gen1_project, self.gen1_span_ids[0])
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"project": -1},
- format="json",
- )
- assert response.status_code == 200, response.content
- data = response.data
- assert data["projects"] == 5
- assert data["transactions"] == 8
- assert data["errors"] == 3
- assert data["performance_issues"] == 2
- def test_with_default(self):
- self.load_trace()
- self.load_default()
- with self.feature(self.FEATURES):
- response = self.client.get(
- self.url,
- data={"project": -1},
- format="json",
- )
- assert response.status_code == 200, response.content
- data = response.data
- assert data["projects"] == 4
- assert data["transactions"] == 8
- assert data["errors"] == 1
- assert data["performance_issues"] == 2
|