Initial setup; unoptimized search query for issues

Author: manessaraj

src/sentry/search/eap/occurrences/attributes.py

@@ -1,3 +1,4 @@
+from sentry.models.group import Group
 from sentry.search.eap import constants
 from sentry.search.eap.columns import (
     ResolvedAttribute,
@@ -6,6 +7,15 @@
 from sentry.search.eap.common_columns import COMMON_COLUMNS, project_virtual_contexts
 from sentry.utils.validators import is_event_id_or_list
 
+
+def group_id_to_issue_processor(group_id: int) -> str:
+    try:
+        grp = Group.objects.filter(id=group_id).first()
+        return grp.qualified_short_id
+    except Group.DoesNotExist:
+        return "Unknown"
+
+
 OCCURRENCE_ATTRIBUTE_DEFINITIONS = {
     column.public_alias: column
     for column in (
@@ -280,6 +290,12 @@
                 internal_name="frame_stack_levels",
                 search_type="string",
             ),
+            ResolvedAttribute(
+                public_alias="issue",
+                internal_name="group_id",
+                search_type="integer",
+                processor=group_id_to_issue_processor,
+            ),
         ]
     )
 }

tests/snuba/api/endpoints/test_organization_events_occurrences.py

@@ -475,3 +475,31 @@ def test_three_issue_uses_single_group_table_query(self) -> None:
             q["sql"] for q in ctx.captured_queries if group_table in q["sql"]
         ]
         assert len(response.data["data"]) == 1
+
+    def test_issues_field_in_response(self) -> None:
+        group1 = self.create_group(project=self.project)
+        group2 = self.create_group(project=self.project)
+        occurrences = [
+            self.create_eap_occurrence(
+                group_id=group1.id,
+                project=self.project,
+                attributes={"fingerprint": ["g1"]},
+            ),
+            self.create_eap_occurrence(
+                group_id=group2.id,
+                project=self.project,
+                attributes={"fingerprint": ["g2"]},
+            ),
+        ]
+        self.store_eap_items(occurrences)
+        response = self.request_with_feature_flag(
+            {
+                "field": ["group_id", "project", "project.name", "issue"],
+                "statsPeriod": "2h",
+                "project": [self.project.id],
+            }
+        )
+        data = sorted(response.data["data"], key=lambda x: x["group_id"])
+        assert len(data) == 2
+        assert data[0]["issue"] == group1.qualified_short_id
+        assert data[1]["issue"] == group2.qualified_short_id