Merge branch 'feat/agents-native-harness-fields' into feat/agents-harness-conversation-logs

Bring in the review fixes from #33. Harness detection now returns a list;
conversation logs stay joined for a single detected harness until the
page handles mixed datasets.

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

Author: VibeSWE

frontend/e2e/agents.spec.ts

@@ -891,3 +891,52 @@ test('Codex conversation logs fill run details from the paired logs dataset', as
   await expect(page).toHaveURL(/logs=none/);
   await expect(page.getByRole('heading', { name: 'No matching runs' })).toBeVisible();
 });
+
+test('discloses the record limit from the queried rows when Codex mapping drops some', async ({
+  page,
+}) => {
+  const trace = 'f6'.repeat(16);
+  const codex = (span: Omit<SpanFixture, 'trace' | 'status'>) =>
+    spanRows({
+      ...span,
+      trace,
+      attributes: { 'service.name': 'codex-app-server', ...span.attributes },
+    });
+  const rows = [
+    codex({
+      id: 'f600000000000001',
+      name: 'session_task.turn',
+      start: base + 1000,
+      duration: 4000,
+      attributes: { model: 'gpt-6-luna', 'codex.turn.token_usage.input_tokens': '10' },
+    }),
+    codex({
+      id: 'f600000000000002',
+      parent: 'f600000000000001',
+      name: 'try_run_sampling_request',
+      start: base + 1100,
+      duration: 3000,
+      attributes: { model: 'gpt-6-luna' },
+    }),
+    // Stream spans count toward the record limit but are not shown as run spans.
+    ...Array.from({ length: 998 }, (_, index) =>
+      codex({
+        id: (index + 1).toString(16).padStart(16, '0'),
+        parent: 'f600000000000002',
+        name: 'receiving_stream',
+        start: base + 1200,
+        duration: 10,
+      }),
+    ),
+  ].flat();
+  await serveAgents(page, {
+    rows,
+    datasets: ['codex-traces'],
+    fields: [...new Set(rows.flatMap((row) => Object.keys(row)))],
+  });
+  await page.goto(`/agents/codex-traces?${range}`);
+  await expect(cell(runRow(page, 'Codex'), 'Spans')).toHaveText('2');
+  await expect(page.getByRole('status').filter({ hasText: 'record limit' })).toContainText(
+    'narrow the time range',
+  );
+});

frontend/src/features/agents/AgentsPage.tsx

@@ -24,7 +24,7 @@ import {
   buildAgentRunQuery,
   discoverAgentDatasets,
 } from '../../lib/agents';
-import { AGENT_HARNESSES, detectAgentHarness, mapHarnessRows } from '../../lib/agentHarnesses';
+import { AGENT_HARNESSES, detectAgentHarnesses, mapHarnessRows } from '../../lib/agentHarnesses';
 import {
   attachHarnessConversation,
   buildHarnessLogQuery,
@@ -123,9 +123,11 @@ export function AgentsPage() {
           buildAgentRunQuery(dataset, fields, bounds, timeColumn),
           signal,
         );
-        const harness = detectAgentHarness(fields);
+        const harnesses = detectAgentHarnesses(fields);
+        // Conversation logs are joined for one harness; a mixed dataset has none yet.
+        const harness = harnesses.length === 1 ? harnesses[0] : undefined;
         return {
-          rows: mapHarnessRows(harness, rows),
+          rows: mapHarnessRows(harnesses, rows),
           limitReached: rows.length >= AGENT_RECORD_LIMIT,
           timeColumn,
           traces: info.logSourceFormats.includes('otel-traces'),
@@ -469,7 +471,7 @@ export function AgentsPage() {
                     the time range to explore them.
                   </p>
                 )}
-                {result.data.rows.length >= AGENT_RECORD_LIMIT && (
+                {result.data.limitReached && (
                   <p role="status" className="agents-warnings">
                     The record limit was reached. Runs may have additional spans or events; narrow
                     the time range to improve coverage.

frontend/src/lib/agentHarnessLogs.test.ts

@@ -44,17 +44,20 @@ const conversations = (run: AgentRun) =>
 const codexTrace = '1b1ef19838e4d610208a394b9af94384';
 const codexRuns = () =>
   buildAgentRuns(
-    mapHarnessRows('codex', [
-      span(codexTrace, 'fe5417199aa59ebf', '57d7ac8056fe8b6d', 'session_task.turn', 15.8, 4, {
-        'service.name': 'codex_exec',
-        model: 'gpt-6-luna',
-      }),
-      span(codexTrace, '67c205c2bacb4518', 'e0d1c4f0b19c5a7e', 'exec', 18, 0.2, {
-        'service.name': 'codex_exec',
-        tool_name: 'exec',
-        call_id: 'call_7b616c08bc894640a843cff3e0f7b38a',
-      }),
-    ]),
+    mapHarnessRows(
+      ['codex'],
+      [
+        span(codexTrace, 'fe5417199aa59ebf', '57d7ac8056fe8b6d', 'session_task.turn', 15.8, 4, {
+          'service.name': 'codex_exec',
+          model: 'gpt-6-luna',
+        }),
+        span(codexTrace, '67c205c2bacb4518', 'e0d1c4f0b19c5a7e', 'exec', 18, 0.2, {
+          'service.name': 'codex_exec',
+          tool_name: 'exec',
+          call_id: 'call_7b616c08bc894640a843cff3e0f7b38a',
+        }),
+      ],
+    ),
   );
 const codexLog = (fields: LogRecord): LogRecord => ({
   'service.name': 'codex_exec',
@@ -121,15 +124,18 @@ const claudeToolOutput = {
 };
 const claudeRuns = () =>
   buildAgentRuns(
-    mapHarnessRows('claude-code', [
-      claudeSpan('671ed833b6b2a759', '', 'claude_code.interaction', 9.5, 6),
-      claudeRequest('first', 9.6),
-      claudeToolSpan,
-      // Flattened span events repeat; the output is shown once.
-      claudeToolOutput,
-      { ...claudeToolOutput },
-      claudeRequest('second', 12.5),
-    ]),
+    mapHarnessRows(
+      ['claude-code'],
+      [
+        claudeSpan('671ed833b6b2a759', '', 'claude_code.interaction', 9.5, 6),
+        claudeRequest('first', 9.6),
+        claudeToolSpan,
+        // Flattened span events repeat; the output is shown once.
+        claudeToolOutput,
+        { ...claudeToolOutput },
+        claudeRequest('second', 12.5),
+      ],
+    ),
   );
 const claudeLog = (sequence: number, seconds: number, fields: LogRecord): LogRecord => ({
   'service.name': 'claude-code',