diff --git a/src/agents/failover-error.test.ts b/src/agents/failover-error.test.ts index 33ffe2d2d..fa8a4e553 100644 --- a/src/agents/failover-error.test.ts +++ b/src/agents/failover-error.test.ts @@ -48,6 +48,22 @@ describe("failover-error", () => { expect(resolveFailoverReasonFromError({ message: "reason: error" })).toBe("timeout"); }); + it("infers timeout from connection/network error messages", () => { + expect(resolveFailoverReasonFromError({ message: "Connection error." })).toBe("timeout"); + expect(resolveFailoverReasonFromError({ message: "fetch failed" })).toBe("timeout"); + expect(resolveFailoverReasonFromError({ message: "Network error: ECONNREFUSED" })).toBe( + "timeout", + ); + expect( + resolveFailoverReasonFromError({ + message: "dial tcp: lookup api.example.com: no such host (ENOTFOUND)", + }), + ).toBe("timeout"); + expect(resolveFailoverReasonFromError({ message: "temporary dns failure EAI_AGAIN" })).toBe( + "timeout", + ); + }); + it("treats AbortError reason=abort as timeout", () => { const err = Object.assign(new Error("aborted"), { name: "AbortError", diff --git a/src/agents/failover-error.ts b/src/agents/failover-error.ts index 63e5c26c7..47660664c 100644 --- a/src/agents/failover-error.ts +++ b/src/agents/failover-error.ts @@ -6,7 +6,7 @@ import { } from "./pi-embedded-helpers.js"; const TIMEOUT_HINT_RE = - /timeout|timed out|deadline exceeded|context deadline exceeded|stop reason:\s*(?:abort|error)|reason:\s*(?:abort|error)|unhandled stop reason:\s*(?:abort|error)/i; + /timeout|timed out|deadline exceeded|context deadline exceeded|connection error|network error|network request failed|fetch failed|socket hang up|econnrefused|econnreset|econnaborted|enotfound|eai_again|stop reason:\s*(?:abort|error)|reason:\s*(?:abort|error)|unhandled stop reason:\s*(?:abort|error)/i; const ABORT_TIMEOUT_RE = /request was aborted|request aborted/i; export class FailoverError extends Error { diff --git a/src/agents/pi-embedded-helpers.isbillingerrormessage.test.ts b/src/agents/pi-embedded-helpers.isbillingerrormessage.test.ts index 11b29abad..c9d073ce8 100644 --- a/src/agents/pi-embedded-helpers.isbillingerrormessage.test.ts +++ b/src/agents/pi-embedded-helpers.isbillingerrormessage.test.ts @@ -415,6 +415,7 @@ describe("isFailoverErrorMessage", () => { "429 rate limit exceeded", "Your credit balance is too low", "request timed out", + "Connection error.", "invalid request format", ]; for (const sample of samples) { @@ -494,6 +495,13 @@ describe("classifyFailoverReason", () => { expect(classifyFailoverReason("credit balance too low")).toBe("billing"); expect(classifyFailoverReason("deadline exceeded")).toBe("timeout"); expect(classifyFailoverReason("request ended without sending any chunks")).toBe("timeout"); + expect(classifyFailoverReason("Connection error.")).toBe("timeout"); + expect(classifyFailoverReason("fetch failed")).toBe("timeout"); + expect(classifyFailoverReason("network error: ECONNREFUSED")).toBe("timeout"); + expect( + classifyFailoverReason("dial tcp: lookup api.example.com: no such host (ENOTFOUND)"), + ).toBe("timeout"); + expect(classifyFailoverReason("temporary dns failure EAI_AGAIN")).toBe("timeout"); expect( classifyFailoverReason( "521 Web server is downCloudflare", diff --git a/src/agents/pi-embedded-helpers/errors.ts b/src/agents/pi-embedded-helpers/errors.ts index 754bd03ba..cfd1460fc 100644 --- a/src/agents/pi-embedded-helpers/errors.ts +++ b/src/agents/pi-embedded-helpers/errors.ts @@ -640,6 +640,14 @@ const ERROR_PATTERNS = { "timed out", "deadline exceeded", "context deadline exceeded", + "connection error", + "network error", + "network request failed", + "fetch failed", + "socket hang up", + /\beconn(?:refused|reset|aborted)\b/i, + /\benotfound\b/i, + /\beai_again\b/i, /without sending (?:any )?chunks?/i, /\bstop reason:\s*(?:abort|error)\b/i, /\breason:\s*(?:abort|error)\b/i,