fix(dashboard-agent): guard repo tools' target, surface a run's queue

Repo tools (get_repo_info/list_files/read_file/search_code) and the
source-read ledger skipped the branch-needs-environment check; add it at
their shared snapshotFor chokepoint. curateRun/curateRuns dropped `queue`
even though schedule_watch now tells the model to use it — the field
wasn't in the API response at all, so add it to the run presenters
(ApiRetrieveRunPresenter, ApiRunListPresenter) and surface it in curation.

Author: kathiekiwi

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

@@ -39,6 +39,7 @@ const commonRunSelect = {
   createdAt: true,
   startedAt: true,
   queuedAt: true,
+  queue: true,
   updatedAt: true,
   completedAt: true,
   expiredAt: true,
@@ -567,6 +568,7 @@ async function createCommonRunStructure(
     createdAt: run.createdAt,
     startedAt: run.startedAt ?? undefined,
     queuedAt: run.queuedAt ?? undefined,
+    queue: run.queue,
     // Mirrors dashboardAgentWatchRunChecks.describeRunWait: a resumed/retried/paused run's
     // queuedAt is a leftover from an earlier enqueue, not this attempt's wait.
     queueWaitReliable: run.queuedAt !== null && !STALE_QUEUED_AT_STATUSES.has(run.status),
@@ -696,6 +698,7 @@ export function synthesiseFoundRunFromBuffer(buffered: SyntheticRun): FoundRun {
     startedAt: null,
     // Buffered runs live in Redis until the drainer replays them into Postgres — never queued there yet.
     queuedAt: null,
+    queue: buffered.queue ?? "",
     updatedAt: buffered.cancelledAt ?? buffered.createdAt,
     // PG-resident SYSTEM_FAILURE rows always have `completedAt` set by
     // the engine; the buffer-synth path must match so SDK consumers

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

@@ -331,6 +331,7 @@ export class ApiRunListPresenter extends BasePresenter {
             delayedUntil: run.delayUntil ? new Date(run.delayUntil) : undefined,
             queuedAt: run.queuedAt ? new Date(run.queuedAt) : undefined,
             queueWaitReliable: run.queueWaitReliable,
+            queue: run.queue,
             isTest: run.isTest,
             ttl: run.ttl ?? undefined,
             expiredAt: run.expiredAt ? new Date(run.expiredAt) : undefined,

internal-packages/dashboard-agent/src/__snapshots__/prompt-prefix.test.ts.snap

@@ -88,8 +88,8 @@ describe("the head-start and agent prefixes are the same prefix", () => {
  * drift. The snapshot below is the itemised diff a reviewer reads.
  */
 const PREFIX_BUDGET = {
-  assistant: { chars: 80_200, estimatedTokens: 20_100, tools: 25, promptChars: 27_500 },
-  code: { chars: 88_000, estimatedTokens: 22_000, tools: 29, promptChars: 30_100 },
+  assistant: { chars: 80_300, estimatedTokens: 20_100, tools: 25, promptChars: 27_500 },
+  code: { chars: 88_100, estimatedTokens: 22_100, tools: 29, promptChars: 30_100 },
 } as const;
 
 describe("the prefix stays inside its budget", () => {

internal-packages/dashboard-agent/src/prompt-prefix.test.ts

@@ -263,3 +263,17 @@ describe("repo-tools", () => {
     expect(res.files).toContain("src/trigger/order.ts");
   });
 });
+
+describe("repo tools: branch without environment", () => {
+  const CASES: Array<[string, any]> = [
+    ["get_repo_info", tools.get_repo_info],
+    ["list_files", tools.list_files],
+    ["read_file", tools.read_file],
+    ["search_code", tools.search_code],
+  ];
+
+  it.each(CASES)("%s is refused before any snapshot fetch", async (_name, tool) => {
+    const res: any = await call(tool, { path: "README.md", branch: "feat/x" });
+    expect(res.error).toBe("branch needs environment: preview or dev.");
+  });
+});

internal-packages/dashboard-agent/src/repo-tools.test.ts

@@ -6,7 +6,12 @@ import { isAbsolute, join, relative, resolve, sep } from "node:path";
 import { promisify } from "node:util";
 import { sliceWellFormed } from "@internal/dashboard-agent-contracts";
 import { tool, type ToolSet } from "ai";
-import { crossProjectTarget, type ApiTarget, type TargetInput } from "./tool-api-client";
+import {
+  crossProjectTarget,
+  targetInputError,
+  type ApiTarget,
+  type TargetInput,
+} from "./tool-api-client";
 import {
   getRepoInfoSchema,
   listFilesSchema,
@@ -225,6 +230,10 @@ export function buildRepoTools(
     runId?: string,
     target?: TargetInput
   ): Promise<RepoSnapshot | { error: string }> {
+    if (target) {
+      const targetError = targetInputError(target);
+      if (targetError) return { error: targetError };
+    }
     if (!runId) return defaultSnapshot;
     if (!resolveRunSnapshot)
       return { error: "Reading a specific run's source isn't available here." };

internal-packages/dashboard-agent/src/repo-tools.ts

@@ -196,6 +196,18 @@ describe("computed run wait", () => {
   });
 });
 
+describe("run queue name", () => {
+  it("carries the run's actual queue name through curateRun", () => {
+    const run = curateRun({ id: "run_1", queue: "task/send-receipt" });
+    expect(run.queue).toBe("task/send-receipt");
+  });
+
+  it("carries the run's actual queue name through curateRuns", () => {
+    const runs = curateRuns({ data: [{ id: "run_1", queue: "my-custom-queue" }] });
+    expect(runs.runs[0]!.queue).toBe("my-custom-queue");
+  });
+});
+
 describe("curateTrace emits spanId", () => {
   it("carries each span's id, required to cite it as evidence", () => {
     const out = curateTrace({

internal-packages/dashboard-agent/src/tool-curation.test.ts

@@ -108,6 +108,7 @@ export function curateRun(run: any) {
     status: run.status,
     taskIdentifier: run.taskIdentifier,
     version: run.version,
+    queue: run.queue,
     isQueued: run.isQueued,
     isExecuting: run.isExecuting,
     isCompleted: run.isCompleted,
@@ -149,6 +150,7 @@ export function curateRuns(data: unknown) {
       status: r.status,
       taskIdentifier: r.taskIdentifier,
       version: r.version,
+      queue: r.queue,
       isTest: r.isTest,
       createdAt: r.createdAt,
       startedAt: r.startedAt,

internal-packages/dashboard-agent/src/tool-curation.ts

@@ -106,7 +106,7 @@ export const listRunsSchema = tool({
 });
 
 export const getRunSchema = tool({
-  description: `Get the status, timing, cost, and error details for a single run in the current environment, by its run id (run_...). The \`wait\` field is the already-computed queue wait (or, when unreliable, time since creation) — never recompute it from createdAt/startedAt. A 404 (in the error message) means this run isn't in this scope, never that it doesn't exist: call locate, then retry here with the scope it names.`,
+  description: `Get the status, timing, cost, and error details for a single run in the current environment, by its run id (run_...). The \`wait\` field is the already-computed queue wait (or, when unreliable, time since creation) — never recompute it from createdAt/startedAt. \`queue\` is the run's actual queue name — use it for schedule_watch or get_queue, never guess. A 404 (in the error message) means this run isn't in this scope, never that it doesn't exist: call locate, then retry here with the scope it names.`,
   inputSchema: z.object({
     runId: z.string().describe("The run id, e.g. run_abc123."),
     ...targetFields,

internal-packages/dashboard-agent/src/tool-schemas.ts

@@ -1,5 +1,5 @@
 import type { ToolSet } from "ai";
-import { apiGet, crossProjectTarget, type ApiTarget } from "./tool-api-client";
+import { apiGet, crossProjectTarget, targetInputError, type ApiTarget } from "./tool-api-client";
 import type { RepoSnapshot } from "./repo-tools";
 
 /**
@@ -137,7 +137,7 @@ export function createSourceReadLedger(ctx: SourceLedgerContext): SourceReadLedg
         execute: async (input: any, options: any) => {
           const result = await execute(input, options);
           const path = (result as { path?: string } | undefined)?.path;
-          if (path && !(result as { error?: unknown }).error) {
+          if (path && !(result as { error?: unknown }).error && !targetInputError(input ?? {})) {
             const snap = input?.runId
               ? await resolveRunSnapshot(input.runId, crossProjectTarget(input))
               : ctx.repoSnapshot;