feat(seer): Add lightweight RCA clustering endpoint integration

Call Seer's new /v0/issues/supergroups/cluster-lightweight endpoint
on new issue creation, gated per-org via sentry-options. This sends
issue event data to Seer for lightweight root cause analysis and
clustering into supergroups.

Also renames the existing explorer-based lightweight RCA files to
explorer_lightweight_rca to avoid confusion with the new direct
endpoint-based clustering approach.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: yuvmen

src/sentry/options/defaults.py

@@ -1343,6 +1343,19 @@
     flags=FLAG_MODIFIABLE_RATE | FLAG_AUTOMATOR_MODIFIABLE,
 )
 
+# Supergroups / Lightweight RCA
+register(
+    "supergroups.active-rca-source",
+    default="explorer",
+    flags=FLAG_AUTOMATOR_MODIFIABLE,
+)
+register(
+    "supergroups.lightweight-enabled-orgs",
+    type=Sequence,
+    default=[],
+    flags=FLAG_ALLOW_EMPTY | FLAG_AUTOMATOR_MODIFIABLE,
+)
+
 # ## sentry.killswitches
 #
 # The following options are documented in sentry.killswitches in more detail

src/sentry/seer/autofix/issue_summary.py

@@ -45,7 +45,7 @@
     make_signed_seer_api_request,
     make_summarize_issue_request,
 )
-from sentry.seer.supergroups.lightweight_rca import trigger_lightweight_rca
+from sentry.seer.supergroups.explorer_lightweight_rca import trigger_explorer_lightweight_rca
 from sentry.services import eventstore
 from sentry.services.eventstore.models import Event, GroupEvent
 from sentry.tasks.base import instrumented_task
@@ -226,10 +226,10 @@ def _trigger_autofix_task(
                 stopping_point=stopping_point,
             )
             try:
-                trigger_lightweight_rca(group)
+                trigger_explorer_lightweight_rca(group)
             except Exception:
                 logger.exception(
-                    "lightweight_rca.trigger_error_in_trigger_autofix_task",
+                    "explorer_lightweight_rca.trigger_error_in_trigger_autofix_task",
                     extra={"group_id": group_id},
                 )
         else:

src/sentry/seer/signed_seer_api.py

@@ -259,6 +259,14 @@ class SupergroupsEmbeddingRequest(TypedDict):
     artifact_data: dict[str, Any]
 
 
+class LightweightRCAClusterRequest(TypedDict):
+    group_id: int
+    issue: dict[str, Any]
+    organization_slug: str
+    organization_id: int
+    project_id: int
+
+
 class SupergroupsListRequest(TypedDict):
     organization_id: int
     offset: NotRequired[int | None]
@@ -375,6 +383,20 @@ def make_supergroups_embedding_request(
     )
 
 
+def make_lightweight_rca_cluster_request(
+    body: LightweightRCAClusterRequest,
+    timeout: int | float | None = None,
+    viewer_context: SeerViewerContext | None = None,
+) -> BaseHTTPResponse:
+    return make_signed_seer_api_request(
+        seer_autofix_default_connection_pool,
+        "/v0/issues/supergroups/cluster-lightweight",
+        body=orjson.dumps(body),
+        timeout=timeout,
+        viewer_context=viewer_context,
+    )
+
+
 def make_supergroups_list_request(
     body: SupergroupsListRequest,
     viewer_context: SeerViewerContext,

…ntry/seer/supergroups/lightweight_rca.py …/supergroups/explorer_lightweight_rca.pysrc/sentry/seer/supergroups/lightweight_rca.py renamed to src/sentry/seer/supergroups/explorer_lightweight_rca.py src/sentry/seer/supergroups/lightweight_rca.py renamed to src/sentry/seer/supergroups/explorer_lightweight_rca.py

@@ -10,7 +10,7 @@
 logger = logging.getLogger(__name__)
 
 
-def trigger_lightweight_rca(group: Group) -> int | None:
+def trigger_explorer_lightweight_rca(group: Group) -> int | None:
     """
     Trigger a lightweight Explorer RCA run for the given group.
 
@@ -26,7 +26,7 @@ def trigger_lightweight_rca(group: Group) -> int | None:
     """
     has_feature = features.has("projects:supergroup-lightweight-rca", group.project)
     logger.info(
-        "lightweight_rca.feature_flag_check",
+        "explorer_lightweight_rca.feature_flag_check",
         extra={
             "group_id": group.id,
             "project_id": group.project.id,
@@ -66,7 +66,7 @@ def trigger_lightweight_rca(group: Group) -> int | None:
         )
 
         logger.info(
-            "lightweight_rca.starting_run",
+            "explorer_lightweight_rca.starting_run",
             extra={
                 "group_id": group.id,
                 "project_id": group.project.id,
@@ -83,7 +83,7 @@ def trigger_lightweight_rca(group: Group) -> int | None:
         )
 
         logger.info(
-            "lightweight_rca.run_started",
+            "explorer_lightweight_rca.run_started",
             extra={
                 "group_id": group.id,
                 "project_id": group.project.id,
@@ -94,7 +94,7 @@ def trigger_lightweight_rca(group: Group) -> int | None:
         return run_id
     except Exception:
         logger.exception(
-            "lightweight_rca.trigger_failed",
+            "explorer_lightweight_rca.trigger_failed",
             extra={
                 "group_id": group.id,
                 "organization_id": group.organization.id,

src/sentry/seer/supergroups/lightweight_rca_cluster.py

@@ -0,0 +1,76 @@
+from __future__ import annotations
+
+import logging
+
+from sentry import options
+from sentry.api.serializers import EventSerializer, serialize
+from sentry.eventstore import backend as eventstore
+from sentry.models.group import Group
+from sentry.seer.models import SeerApiError
+from sentry.seer.signed_seer_api import (
+    LightweightRCAClusterRequest,
+    SeerViewerContext,
+    make_lightweight_rca_cluster_request,
+)
+
+logger = logging.getLogger(__name__)
+
+
+def trigger_lightweight_rca_cluster(group: Group) -> None:
+    """
+    Call Seer's lightweight RCA clustering endpoint for the given group.
+
+    Sends issue event data to Seer, which generates a lightweight root cause analysis
+    and clusters the issue into supergroups based on embedding similarity.
+    """
+    enabled_orgs: list[int] = options.get("supergroups.lightweight-enabled-orgs")
+    if group.organization.id not in enabled_orgs:
+        return
+
+    event = group.get_recommended_event_for_environments()
+    if not event:
+        event = group.get_latest_event()
+
+    if not event:
+        logger.info(
+            "lightweight_rca_cluster.no_event",
+            extra={"group_id": group.id},
+        )
+        return
+
+    ready_event = eventstore.get_event_by_id(group.project.id, event.event_id, group_id=group.id)
+    if not ready_event:
+        logger.info(
+            "lightweight_rca_cluster.event_not_ready",
+            extra={"group_id": group.id, "event_id": event.event_id},
+        )
+        return
+
+    serialized_event = serialize(ready_event, None, EventSerializer())
+
+    body = LightweightRCAClusterRequest(
+        group_id=group.id,
+        issue={
+            "id": group.id,
+            "title": group.title,
+            "short_id": group.qualified_short_id,
+            "events": [serialized_event],
+        },
+        organization_slug=group.organization.slug,
+        organization_id=group.organization.id,
+        project_id=group.project.id,
+    )
+    viewer_context = SeerViewerContext(organization_id=group.organization.id)
+
+    response = make_lightweight_rca_cluster_request(body, timeout=30, viewer_context=viewer_context)
+    if response.status >= 400:
+        raise SeerApiError("Lightweight RCA cluster request failed", response.status)
+
+    logger.info(
+        "lightweight_rca_cluster.success",
+        extra={
+            "group_id": group.id,
+            "project_id": group.project.id,
+            "organization_id": group.organization.id,
+        },
+    )

src/sentry/tasks/post_process.py

@@ -1578,6 +1578,22 @@ def kick_off_seer_automation(job: PostProcessJob) -> None:
             )
 
 
+def kick_off_lightweight_rca_cluster(job: PostProcessJob) -> None:
+    from sentry.tasks.seer.lightweight_rca_cluster import trigger_lightweight_rca_cluster_task
+
+    if not job["group_state"]["is_new"]:
+        return
+
+    event = job["event"]
+    group = event.group
+
+    enabled_orgs: list[int] = options.get("supergroups.lightweight-enabled-orgs")
+    if group.organization.id not in enabled_orgs:
+        return
+
+    trigger_lightweight_rca_cluster_task.delay(group.id)
+
+
 GROUP_CATEGORY_POST_PROCESS_PIPELINE = {
     GroupCategory.ERROR: [
         _capture_group_stats,
@@ -1588,6 +1604,7 @@ def kick_off_seer_automation(job: PostProcessJob) -> None:
         handle_owner_assignment,
         handle_auto_assignment,
         kick_off_seer_automation,
+        kick_off_lightweight_rca_cluster,
         process_workflow_engine_issue_alerts,
         process_resource_change_bounds,
         process_data_forwarding,

src/sentry/tasks/seer/lightweight_rca_cluster.py

@@ -0,0 +1,34 @@
+import logging
+
+from sentry.models.group import Group
+from sentry.tasks.base import instrumented_task
+from sentry.taskworker.namespaces import issues_tasks
+
+logger = logging.getLogger(__name__)
+
+
+@instrumented_task(
+    name="sentry.tasks.seer.lightweight_rca_cluster.trigger_lightweight_rca_cluster_task",
+    queue="default",
+    max_retries=0,
+    taskworker_namespace=issues_tasks,
+)
+def trigger_lightweight_rca_cluster_task(group_id: int, **kwargs) -> None:
+    from sentry.seer.supergroups.lightweight_rca_cluster import trigger_lightweight_rca_cluster
+
+    try:
+        group = Group.objects.get(id=group_id)
+    except Group.DoesNotExist:
+        logger.info(
+            "lightweight_rca_cluster_task.group_not_found",
+            extra={"group_id": group_id},
+        )
+        return
+
+    try:
+        trigger_lightweight_rca_cluster(group)
+    except Exception:
+        logger.exception(
+            "lightweight_rca_cluster_task.failed",
+            extra={"group_id": group_id},
+        )

tests/sentry/seer/autofix/test_issue_summary.py

@@ -960,14 +960,14 @@ def setUp(self) -> None:
         event_data = load_data("python")
         self.event = self.store_event(data=event_data, project_id=self.project.id)
 
-    @patch("sentry.seer.autofix.issue_summary.trigger_lightweight_rca")
+    @patch("sentry.seer.autofix.issue_summary.trigger_explorer_lightweight_rca")
     @patch("sentry.seer.autofix.issue_summary.trigger_autofix_explorer", return_value=42)
     def test_lightweight_rca_called_on_explorer_path(
         self,
         mock_explorer,
-        mock_lightweight_rca,
+        mock_explorer_lightweight_rca,
     ):
-        """trigger_lightweight_rca is called when the explorer path is taken"""
+        """trigger_explorer_lightweight_rca is called when the explorer path is taken"""
         _trigger_autofix_task(
             group_id=self.group.id,
             event_id=self.event.event_id,
@@ -976,18 +976,18 @@ def test_lightweight_rca_called_on_explorer_path(
         )
 
         mock_explorer.assert_called_once()
-        mock_lightweight_rca.assert_called_once_with(self.group)
+        mock_explorer_lightweight_rca.assert_called_once_with(self.group)
 
-    @patch("sentry.seer.autofix.issue_summary.trigger_lightweight_rca")
+    @patch("sentry.seer.autofix.issue_summary.trigger_explorer_lightweight_rca")
     @patch(
         "sentry.seer.autofix.issue_summary.trigger_autofix", return_value=Mock(data={"run_id": 42})
     )
     def test_lightweight_rca_not_called_on_legacy_path(
         self,
         mock_autofix,
-        mock_lightweight_rca,
+        mock_explorer_lightweight_rca,
     ):
-        """trigger_lightweight_rca is NOT called on the legacy autofix path"""
+        """trigger_explorer_lightweight_rca is NOT called on the legacy autofix path"""
         with self.feature(
             {
                 "organizations:seer-explorer": False,
@@ -1002,17 +1002,17 @@ def test_lightweight_rca_not_called_on_legacy_path(
             )
 
         mock_autofix.assert_called_once()
-        mock_lightweight_rca.assert_not_called()
+        mock_explorer_lightweight_rca.assert_not_called()
 
-    @patch("sentry.seer.autofix.issue_summary.trigger_lightweight_rca")
+    @patch("sentry.seer.autofix.issue_summary.trigger_explorer_lightweight_rca")
     @patch("sentry.seer.autofix.issue_summary.trigger_autofix_explorer", return_value=42)
     def test_lightweight_rca_failure_does_not_block_explorer(
         self,
         mock_explorer,
-        mock_lightweight_rca,
+        mock_explorer_lightweight_rca,
     ):
-        """Failure in trigger_lightweight_rca doesn't prevent the explorer autofix from completing"""
-        mock_lightweight_rca.side_effect = Exception("lightweight RCA failed")
+        """Failure in trigger_explorer_lightweight_rca doesn't prevent the explorer autofix from completing"""
+        mock_explorer_lightweight_rca.side_effect = Exception("lightweight RCA failed")
 
         _trigger_autofix_task(
             group_id=self.group.id,
@@ -1022,7 +1022,7 @@ def test_lightweight_rca_failure_does_not_block_explorer(
         )
 
         mock_explorer.assert_called_once()
-        mock_lightweight_rca.assert_called_once_with(self.group)
+        mock_explorer_lightweight_rca.assert_called_once_with(self.group)
 
 
 class TestFetchUserPreference: