@@ -103,7 +103,6 @@ import type { WsData } from "../ws-bridge";
 import { registerTurn, trackStreamLifetime, unregisterTurn } from "../lifecycle";
 import { redactSecretString } from "../../lib/redact";
 import { readBoundedResponseBody } from "../../lib/bounded-body";
-import { classifyCodexPreStreamRejection } from "../../codex/quota-rejection";
 import type { AdmissionLease } from "../../lib/admission";
 import { supportedLadderFor } from "../effort-policy";
 import { isThreadSpawnRequest } from "../effort-policy";
@@ -247,12 +246,8 @@ async function shouldRetryCodexPoolAccountModel400(
 }
 
 /** Pre-stream quota/billing rejections that warrant one alternate-account attempt (#584). */
-async function shouldRetryCodexPoolAccountQuota(
-  response: Response,
-  signal?: AbortSignal,
-): Promise<boolean> {
-  const rejection = await classifyCodexPreStreamRejection(response, { signal });
-  return rejection.alternateRetryEligible;
+export function shouldRetryCodexPoolAccountQuota(response: Response): boolean {
+  return response.status === 402 || response.status === 429;
 }
 
 interface CodexPoolAccountRetryArgs {
@@ -1630,7 +1625,7 @@ async function handleResponsesInner(
         options.abortSignal,
       )) {
         poolRetryOutcome = 400;
-      } else if (await shouldRetryCodexPoolAccountQuota(upstreamResponse, options.abortSignal)) {
+      } else if (shouldRetryCodexPoolAccountQuota(upstreamResponse)) {
         // Pre-stream only: once SSE has begun, mid-stream quota stays terminal.
         poolRetryOutcome = upstreamResponse.status;
       }
 
@@ -1,5 +1,6 @@
 import { describe, expect, test } from "bun:test";
 import { classifyCodexPreStreamRejection } from "../src/codex/quota-rejection";
+import { shouldRetryCodexPoolAccountQuota } from "../src/server/responses/core";
 
 function jsonRejection(status: number, error: Record<string, unknown>): Response {
   return Response.json({ error }, { status });
@@ -10,6 +11,15 @@ function jsonPayload(status: number, payload: Record<string, unknown>): Response
 }
 
 describe("Codex pre-stream quota rejection classification", () => {
+  test.each([
+    [402, true],
+    [429, true],
+    [400, false],
+    [503, false],
+  ])("selects pool-account retries synchronously for HTTP %i", (status, expected) => {
+    expect(shouldRetryCodexPoolAccountQuota(new Response(null, { status }))).toBe(expected);
+  });
+
   test.each([
     [429, "nested code", { error: { code: "usage_limit_exceeded" } }, "usage_limit_exceeded"],
     [429, "nested type", { error: { type: "insufficient_quota" } }, "insufficient_quota"],