feat(webapp): surface run cell in the run admin panel

Author: nicktrn

apps/webapp/app/presenters/v3/SpanPresenter.server.ts

@@ -106,6 +106,7 @@ export class SpanPresenter extends BasePresenter {
     spanId,
     runFriendlyId,
     linkedRunId,
+    isAdmin,
   }: {
     userId: string;
     projectSlug: string;
@@ -117,6 +118,7 @@ export class SpanPresenter extends BasePresenter {
     spanId: string;
     runFriendlyId: string;
     linkedRunId?: string;
+    isAdmin?: boolean;
   }) {
     const project = await this._replica.project.findFirst({
       where: {
@@ -197,6 +199,7 @@ export class SpanPresenter extends BasePresenter {
       eventRepository: repository,
       spanId,
       linkedRunId,
+      isAdmin,
       createdAt: parentRun.createdAt,
       completedAt: parentRun.completedAt,
       environmentId: parentRun.runtimeEnvironmentId,
@@ -236,6 +239,7 @@ export class SpanPresenter extends BasePresenter {
     eventRepository,
     spanId,
     linkedRunId,
+    isAdmin,
     createdAt,
     completedAt,
   }: {
@@ -245,6 +249,7 @@ export class SpanPresenter extends BasePresenter {
     eventRepository: IEventRepository;
     spanId: string;
     linkedRunId?: string;
+    isAdmin?: boolean;
     createdAt: Date;
     completedAt: Date | null;
   }) {
@@ -382,6 +387,34 @@ export class SpanPresenter extends BasePresenter {
         }
       : undefined;
 
+    // Cell attribution is telemetry-only - a `trigger.cell` resource attribute
+    // on the run's span, never a DB field. Admin-only + best-effort: the span
+    // may not be in the event store yet (queued/buffered/ingestion lag) and the
+    // store may be unreachable, so any failure degrades to undefined rather than
+    // breaking the panel.
+    let cell: string | undefined;
+    if (isAdmin) {
+      try {
+        const rootSpan = await eventRepository.getSpan(
+          eventStore,
+          environmentId,
+          run.spanId,
+          traceId,
+          createdAt,
+          completedAt ?? undefined
+        );
+        const resource = rootSpan?.resourceProperties as Record<string, any> | undefined;
+        const value = resource?.trigger?.cell ?? resource?.["trigger.cell"];
+        cell = typeof value === "string" ? value : undefined;
+      } catch (error) {
+        logger.warn("Failed to resolve run cell from telemetry", {
+          runId: run.id,
+          spanId: run.spanId,
+          error: error instanceof Error ? error.message : String(error),
+        });
+      }
+    }
+
     return {
       id: run.id,
       friendlyId: run.friendlyId,
@@ -453,6 +486,7 @@ export class SpanPresenter extends BasePresenter {
       isBuffered: false,
       machinePreset: machine?.name,
       taskEventStore: run.taskEventStore,
+      cell,
       externalTraceId,
     };
   }

apps/webapp/app/routes/resources.orgs.$organizationSlug.projects.$projectParam.env.$envParam.runs.$runParam.spans.$spanParam/route.tsx

@@ -84,7 +84,7 @@ import { useHasAdminAccess } from "~/hooks/useUser";
 import { redirectWithErrorMessage } from "~/models/message.server";
 import { type Span, SpanPresenter, type SpanRun } from "~/presenters/v3/SpanPresenter.server";
 import { logger } from "~/services/logger.server";
-import { requireUserId } from "~/services/session.server";
+import { requireUser } from "~/services/session.server";
 import { cn } from "~/utils/cn";
 import { formatCurrencyAccurate } from "~/utils/numberFormatter";
 import {
@@ -108,7 +108,10 @@ import { RealtimeStreamViewer } from "../resources.orgs.$organizationSlug.projec
 import { CompleteWaitpointForm } from "../resources.orgs.$organizationSlug.projects.$projectParam.env.$envParam.waitpoints.$waitpointFriendlyId.complete/route";
 
 export const loader = async ({ request, params }: LoaderFunctionArgs) => {
-  const userId = await requireUserId(request);
+  const user = await requireUser(request);
+  // Admin gate for the telemetry-backed "Cell" field — only admins trigger the
+  // extra event-store read (below), and only admins see the panel.
+  const isAdmin = user.admin || user.isImpersonating;
   const { projectParam, organizationSlug, envParam, runParam, spanParam } =
     v3SpanParamsSchema.parse(params);
 
@@ -123,7 +126,8 @@ export const loader = async ({ request, params }: LoaderFunctionArgs) => {
       envSlug: envParam,
       spanId: spanParam,
       runFriendlyId: runParam,
-      userId,
+      userId: user.id,
+      isAdmin,
       linkedRunId,
     });
 
@@ -1044,6 +1048,10 @@ function RunBody({
                       <Property.Label>Task event store</Property.Label>
                       <Property.Value>{run.taskEventStore}</Property.Value>
                     </Property.Item>
+                    <Property.Item>
+                      <Property.Label>Cell</Property.Label>
+                      <Property.Value>{run.cell ?? "-"}</Property.Value>
+                    </Property.Item>
                   </div>
                 )}
               </Property.Table>

apps/webapp/app/v3/mollifier/syntheticSpanRun.server.ts

@@ -198,6 +198,7 @@ export async function buildSyntheticSpanRun(args: {
     isBuffered: true,
     machinePreset: narrowMachinePreset(run.machinePreset),
     taskEventStore: "taskEvent",
+    cell: undefined,
     externalTraceId: undefined,
   };
 }