feat(search agent): Start and poll the agent state

src/sentry/api/urls.py

@@ -547,6 +547,8 @@
 from sentry.seer.endpoints.organization_seer_setup_check import OrganizationSeerSetupCheckEndpoint
 from sentry.seer.endpoints.organization_trace_summary import OrganizationTraceSummaryEndpoint
 from sentry.seer.endpoints.project_seer_preferences import ProjectSeerPreferencesEndpoint
+from sentry.seer.endpoints.search_agent_start import SearchAgentStartEndpoint
+from sentry.seer.endpoints.search_agent_state import SearchAgentStateEndpoint
 from sentry.seer.endpoints.seer_rpc import SeerRpcServiceEndpoint
 from sentry.seer.endpoints.trace_explorer_ai_query import TraceExplorerAIQuery
 from sentry.seer.endpoints.trace_explorer_ai_setup import TraceExplorerAISetup
@@ -2368,6 +2370,16 @@ def create_group_urls(name_prefix: str) -> list[URLPattern | URLResolver]:
         SearchAgentTranslateEndpoint.as_view(),
         name="sentry-api-0-search-agent-translate",
     ),
+    re_path(
+        r"^(?P<organization_id_or_slug>[^/]+)/search-agent/start/$",
+        SearchAgentStartEndpoint.as_view(),
+        name="sentry-api-0-search-agent-start",
+    ),
+    re_path(
+        r"^(?P<organization_id_or_slug>[^/]+)/search-agent/state/(?P<run_id>[^/]+)/$",
+        SearchAgentStateEndpoint.as_view(),
+        name="sentry-api-0-search-agent-state",
+    ),
     re_path(
         r"^(?P<organization_id_or_slug>[^/]+)/seer/explorer-chat/(?:(?P<run_id>[^/]+)/)?$",
         OrganizationSeerExplorerChatEndpoint.as_view(),

src/sentry/seer/endpoints/search_agent_start.py

@@ -0,0 +1,226 @@
+from __future__ import annotations
+
+import logging
+from typing import Any
+
+import orjson
+import requests
+from django.conf import settings
+from rest_framework import serializers, status
+from rest_framework.request import Request
+from rest_framework.response import Response
+
+from sentry import features
+from sentry.api.api_owners import ApiOwner
+from sentry.api.api_publish_status import ApiPublishStatus
+from sentry.api.base import region_silo_endpoint
+from sentry.api.bases import OrganizationEndpoint
+from sentry.models.organization import Organization
+from sentry.seer.endpoints.trace_explorer_ai_setup import OrganizationTraceExplorerAIPermission
+from sentry.seer.explorer.client_utils import collect_user_org_context
+from sentry.seer.seer_setup import has_seer_access_with_detail
+from sentry.seer.signed_seer_api import sign_with_seer_secret
+
+logger = logging.getLogger(__name__)
+
+
+class SearchAgentStartSerializer(serializers.Serializer):
+    project_ids = serializers.ListField(
+        child=serializers.IntegerField(),
+        required=True,
+        allow_empty=False,
+        help_text="List of project IDs to search in.",
+    )
+    natural_language_query = serializers.CharField(
+        required=True,
+        allow_blank=False,
+        help_text="Natural language query to translate.",
+    )
+    strategy = serializers.CharField(
+        required=False,
+        default="Traces",
+        help_text="Search strategy to use (Traces, Issues, Logs, Errors).",
+    )
+    options = serializers.DictField(
+        required=False,
+        allow_null=True,
+        help_text="Optional configuration options.",
+    )
+
+    def validate_options(self, value: dict[str, Any] | None) -> dict[str, Any] | None:
+        if value is None:
+            return None
+        if "model_name" in value and not isinstance(value["model_name"], str):
+            raise serializers.ValidationError("model_name must be a string")
+        return value
+
+
+def send_search_agent_start_request(
+    org_id: int,
+    org_slug: str,
+    project_ids: list[int],
+    natural_language_query: str,
+    strategy: str = "Traces",
+    user_email: str | None = None,
+    timezone: str | None = None,
+    model_name: str | None = None,
+) -> dict[str, Any]:
+    """
+    Sends a request to Seer to start an async search agent and returns a run_id for polling.
+    """
+    body_dict: dict[str, Any] = {
+        "org_id": org_id,
+        "org_slug": org_slug,
+        "project_ids": project_ids,
+        "natural_language_query": natural_language_query,
+        "strategy": strategy,
+    }
+
+    if user_email:
+        body_dict["user_email"] = user_email
+
+    if timezone:
+        body_dict["timezone"] = timezone
+
+    options: dict[str, Any] = {}
+    if model_name is not None:
+        options["model_name"] = model_name
+
+    if options:
+        body_dict["options"] = options
+
+    body = orjson.dumps(body_dict)
+
+    response = requests.post(
+        f"{settings.SEER_AUTOFIX_URL}/v1/assisted-query/start",
+        data=body,
+        headers={
+            "content-type": "application/json;charset=utf-8",
+            **sign_with_seer_secret(body),
+        },
+    )
+    response.raise_for_status()
+    return response.json()
+
+
+@region_silo_endpoint
+class SearchAgentStartEndpoint(OrganizationEndpoint):
+    """
+    Endpoint to start an async search agent and return a run_id for polling.
+
+    This starts the agent processing in the background and immediately returns
+    a run_id that can be used with the /search-agent/state/ endpoint to poll
+    for progress and results.
+    """
+
+    publish_status = {
+        "POST": ApiPublishStatus.EXPERIMENTAL,
+    }
+    owner = ApiOwner.ML_AI
+
+    permission_classes = (OrganizationTraceExplorerAIPermission,)
+
+    def post(self, request: Request, organization: Organization) -> Response:
+        """
+        Start an async search agent and return a run_id for polling.
+
+        Returns:
+            {"run_id": int}
+        """
+        serializer = SearchAgentStartSerializer(data=request.data)
+        if not serializer.is_valid():
+            return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
+
+        validated_data = serializer.validated_data
+        natural_language_query = validated_data["natural_language_query"]
+        strategy = validated_data.get("strategy", "Traces")
+        options = validated_data.get("options") or {}
+        model_name = options.get("model_name")
+
+        projects = self.get_projects(
+            request, organization, project_ids=set(validated_data["project_ids"])
+        )
+        project_ids = [project.id for project in projects]
+
+        if not features.has(
+            "organizations:gen-ai-search-agent-translate", organization, actor=request.user
+        ):
+            return Response(
+                {"detail": "Feature flag not enabled"},
+                status=status.HTTP_403_FORBIDDEN,
+            )
+
+        has_seer_access, detail = has_seer_access_with_detail(organization, actor=request.user)
+        if not has_seer_access:
+            return Response(
+                {"detail": detail},
+                status=status.HTTP_403_FORBIDDEN,
+            )
+
+        if not settings.SEER_AUTOFIX_URL:
+            return Response(
+                {"detail": "Seer is not properly configured."},
+                status=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            )
+
+        # Collect user context for the agent
+        user_org_context = collect_user_org_context(request.user, organization)
+        user_email = user_org_context.get("user_email")
+        timezone = user_org_context.get("user_timezone")
+
+        try:
+            data = send_search_agent_start_request(
+                organization.id,
+                organization.slug,
+                project_ids,
+                natural_language_query,
+                strategy=strategy,
+                user_email=user_email,
+                timezone=timezone,
+                model_name=model_name,
+            )
+
+            # Validate that run_id is present in the response
+            run_id = data.get("run_id")
+            if run_id is None:
+                logger.error(
+                    "search_agent.missing_run_id",
+                    extra={
+                        "organization_id": organization.id,
+                        "project_ids": project_ids,
+                        "response_data": data,
+                    },
+                )
+                return Response(
+                    {"detail": "Failed to start search agent: missing run_id in response"},
+                    status=status.HTTP_500_INTERNAL_SERVER_ERROR,
+                )
+
+            # Return the run_id for polling
+            return Response({"run_id": run_id})
+
+        except requests.HTTPError as e:
+            logger.exception(
+                "search_agent.start_error",
+                extra={
+                    "organization_id": organization.id,
+                    "project_ids": project_ids,
+                    "status_code": e.response.status_code if e.response is not None else None,
+                },
+            )
+            return Response(
+                {"detail": "Failed to start search agent"},
+                status=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            )
+        except Exception:
+            logger.exception(
+                "search_agent.start_error",
+                extra={
+                    "organization_id": organization.id,
+                    "project_ids": project_ids,
+                },
+            )
+            return Response(
+                {"detail": "Failed to start search agent"},
+                status=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            )