1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702 |
- 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_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_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_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_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_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 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 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
- # 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 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_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_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_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"]
- 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_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_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_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
|