ref(seer): Split lightweight RCA clustering into separate read/write flags

- Write: organizations:supergroups-lightweight-rca-clustering-write
  (controls post_process task dispatch for generating embeddings)
- Read: organizations:supergroups-lightweight-rca-clustering-read
  (controls which rca_source supergroup query endpoints use)

Allows enabling write ahead of read to accumulate embeddings before
switching what users see.

Author: yuvmen

src/sentry/features/temporary.py

@@ -571,8 +571,10 @@ def register_temporary_features(manager: FeatureManager) -> None:
     manager.add("projects:supergroup-embeddings-explorer", ProjectFeature, FeatureHandlerStrategy.FLAGPOLE, api_expose=False)
     # Enable lightweight Explorer RCA runs for supergroup quality evaluation
     manager.add("projects:supergroup-lightweight-rca", ProjectFeature, FeatureHandlerStrategy.FLAGPOLE, api_expose=False)
-    # Use lightweight RCA source for supergroup clustering and queries
-    manager.add("organizations:supergroups-lightweight-rca-clustering", OrganizationFeature, FeatureHandlerStrategy.FLAGPOLE, api_expose=False)
+    # Enable lightweight RCA clustering write path (generate embeddings on new issues)
+    manager.add("organizations:supergroups-lightweight-rca-clustering-write", OrganizationFeature, FeatureHandlerStrategy.FLAGPOLE, api_expose=False)
+    # Enable lightweight RCA clustering read path (query lightweight embeddings in supergroup APIs)
+    manager.add("organizations:supergroups-lightweight-rca-clustering-read", OrganizationFeature, FeatureHandlerStrategy.FLAGPOLE, api_expose=False)
 
     manager.add("projects:workflow-engine-performance-detectors", ProjectFeature, FeatureHandlerStrategy.FLAGPOLE, api_expose=False)
 

src/sentry/seer/supergroups/endpoints/organization_supergroup_details.py

@@ -37,7 +37,9 @@ def get(self, request: Request, organization: Organization, supergroup_id: int)
 
         rca_source = (
             RCASource.LIGHTWEIGHT
-            if features.has("organizations:supergroups-lightweight-rca-clustering", organization)
+            if features.has(
+                "organizations:supergroups-lightweight-rca-clustering-read", organization
+            )
             else RCASource.EXPLORER
         )
 

src/sentry/seer/supergroups/endpoints/organization_supergroups_by_group.py

@@ -80,7 +80,9 @@ def get(self, request: Request, organization: Organization) -> Response:
 
         rca_source = (
             RCASource.LIGHTWEIGHT
-            if features.has("organizations:supergroups-lightweight-rca-clustering", organization)
+            if features.has(
+                "organizations:supergroups-lightweight-rca-clustering-read", organization
+            )
             else RCASource.EXPLORER
         )
 

src/sentry/tasks/post_process.py

@@ -1593,7 +1593,9 @@ def kick_off_lightweight_rca_cluster(job: PostProcessJob) -> None:
     event = job["event"]
     group = event.group
 
-    if not features.has("organizations:supergroups-lightweight-rca-clustering", group.organization):
+    if not features.has(
+        "organizations:supergroups-lightweight-rca-clustering-write", group.organization
+    ):
         return
 
     trigger_lightweight_rca_cluster_task.delay(group.id)

tests/sentry/seer/supergroups/endpoints/test_organization_supergroup_details.py

@@ -58,7 +58,7 @@ def test_rca_source_lightweight_when_flag_enabled(self, mock_seer):
         with self.feature(
             {
                 "organizations:top-issues-ui": True,
-                "organizations:supergroups-lightweight-rca-clustering": True,
+                "organizations:supergroups-lightweight-rca-clustering-read": True,
             }
         ):
             self.get_success_response(self.organization.slug, "1")

tests/sentry/seer/supergroups/endpoints/test_organization_supergroups_by_group.py

@@ -99,7 +99,7 @@ def test_rca_source_lightweight_when_flag_enabled(self, mock_seer):
         with self.feature(
             {
                 "organizations:top-issues-ui": True,
-                "organizations:supergroups-lightweight-rca-clustering": True,
+                "organizations:supergroups-lightweight-rca-clustering-read": True,
             }
         ):
             self.get_success_response(

tests/sentry/tasks/test_post_process.py

@@ -3078,7 +3078,7 @@ def test_kick_off_lightweight_rca_cluster_when_enabled(self, mock_task):
             project_id=self.project.id,
         )
 
-        with self.feature("organizations:supergroups-lightweight-rca-clustering"):
+        with self.feature("organizations:supergroups-lightweight-rca-clustering-write"):
             self.call_post_process_group(
                 is_new=True,
                 is_regression=False,
@@ -3111,7 +3111,7 @@ def test_kick_off_lightweight_rca_cluster_skips_when_not_new(self, mock_task):
             project_id=self.project.id,
         )
 
-        with self.feature("organizations:supergroups-lightweight-rca-clustering"):
+        with self.feature("organizations:supergroups-lightweight-rca-clustering-write"):
             self.call_post_process_group(
                 is_new=False,
                 is_regression=False,