ref(codeowners): Add analytics for issue owners rate limiting (#44929)

Creates an analytic event to track the events getting ratelimited by the
Issue Owners ratelimit

WOR-2682

Author: jangjodi

src/sentry/tasks/__init__.py

@@ -1,3 +1,5 @@
+from .analytics import *  # NOQA
+
 """Celery tasks.
 
 Celery tasks are used to create asynchronous workers which communicate their tasks via a

src/sentry/tasks/analytics.py

@@ -0,0 +1,15 @@
+from sentry import analytics
+
+
+class IssueOwnersEventRatelimited(analytics.Event):
+    type = "issue_owners_event.ratelimited"
+
+    attributes = (
+        analytics.Attribute("event_id"),
+        analytics.Attribute("group_id"),
+        analytics.Attribute("project_id"),
+        analytics.Attribute("organization_id"),
+    )
+
+
+analytics.register(IssueOwnersEventRatelimited)

src/sentry/tasks/post_process.py

@@ -8,7 +8,7 @@
 from django.conf import settings
 from django.utils import timezone
 
-from sentry import features
+from sentry import analytics, features
 from sentry.exceptions import PluginError
 from sentry.issues.grouptype import GroupCategory
 from sentry.issues.issue_occurrence import IssueOccurrence
@@ -180,6 +180,13 @@ def handle_owner_assignment(job):
                                 "reason": "ratelimited",
                             },
                         )
+                        analytics.record(
+                            "issue_owners_event.ratelimited",
+                            event_id=event.event_id,
+                            group_id=event.group_id,
+                            project_id=event.project_id,
+                            organization_id=event.project.organization_id,
+                        )
                         return
 
                 with sentry_sdk.start_span(

tests/sentry/tasks/test_post_process.py

@@ -989,8 +989,9 @@ def test_debounces_handle_owner_assignments(self, logger):
             },
         )
 
+    @patch("sentry.analytics.record")
     @patch("sentry.tasks.post_process.logger")
-    def test_issue_owners_should_ratelimit(self, logger):
+    def test_issue_owners_should_ratelimit(self, logger, record_mock):
         cache.set(
             f"issue_owner_assignment_ratelimit:{self.project.id}",
             (ISSUE_OWNERS_PER_PROJECT_PER_MIN_RATELIMIT, datetime.now()),
@@ -1020,6 +1021,13 @@ def test_issue_owners_should_ratelimit(self, logger):
                 "reason": "ratelimited",
             },
         )
+        record_mock.assert_called_with(
+            "issue_owners_event.ratelimited",
+            event_id=event.event_id,
+            group_id=event.group_id,
+            project_id=event.project_id,
+            organization_id=event.project.organization_id,
+        )
 
 
 class ProcessCommitsTestMixin(BasePostProgressGroupMixin):