diff --git a/src/selfhost/queue-common.ts b/src/selfhost/queue-common.ts index 45583acebb..a7c62699b5 100644 --- a/src/selfhost/queue-common.ts +++ b/src/selfhost/queue-common.ts @@ -689,10 +689,6 @@ export function githubRateLimitRetryDelayMs( return null; } -export function nonConsumingRetryDelayMs(error: unknown): number | null { - return githubRateLimitRetryDelayMs(error); -} - export function consumingRetryDelayMs( error: unknown, defaultDelayMs: number, diff --git a/test/unit/selfhost-queue-common.test.ts b/test/unit/selfhost-queue-common.test.ts index 1948e42a17..72e50476c0 100644 --- a/test/unit/selfhost-queue-common.test.ts +++ b/test/unit/selfhost-queue-common.test.ts @@ -25,7 +25,6 @@ import { jobClaimSortKey, jobPriority, matchesGitHubRateLimitAdmissionTarget, - nonConsumingRetryDelayMs, parsePositiveIntEnv, queueBackgroundConcurrency, queueDeadLetterAutoRetryMaxExtraAttempts, @@ -1481,25 +1480,6 @@ describe("self-host queue common helpers", () => { ).toBeNull(); }); - it("keeps only GitHub rate limits on the non-consuming retry path", () => { - expect(nonConsumingRetryDelayMs(new Error("boom"))).toBeNull(); - expect( - nonConsumingRetryDelayMs({ - status: 429, - response: { headers: new Headers({ "retry-after": "2" }) }, - }), - ).toBe(2_000); - expect( - nonConsumingRetryDelayMs( - new RetryableJobError("AI review pending", { - retryAfterMs: 1234, - retryKind: "ai_review_public_summary_missing", - }), - ), - ).toBeNull(); - expect(nonConsumingRetryDelayMs(new Error("openai rate limit"))).toBeNull(); - }); - it("uses RetryableJobError delays on the bounded consuming retry path", () => { expect(consumingRetryDelayMs(new Error("boom"), 77)).toBe(77); expect(