fix(webapp): retry driver-adapter connectivity errors in the mollifier drainer

isRetryablePgError only recognized the Rust engine's DB-unreachable shapes (P1001
/ "Can't reach database server"). Under a driver adapter the same outage surfaces
as P2010 "Database not reachable" / ECONNREFUSED / ENOTFOUND, so buffered runs
were permanently failed on a transient outage. Reuse the shared
looksLikeConnectivityError predicate (now exported from prismaErrors) so those
are retried too.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: ericallam

apps/webapp/app/utils/prismaErrors.ts

@@ -38,7 +38,7 @@ const CONNECTIVITY_ERRNO = new Set([
 const CONNECTIVITY_MESSAGE =
   /ECONNREFUSED|ENOTFOUND|ETIMEDOUT|ECONNRESET|EHOSTUNREACH|database not reachable|can't reach database|connection terminated|server has closed the connection|timed out fetching a new connection/i;
 
-function looksLikeConnectivityError(error: unknown): boolean {
+export function looksLikeConnectivityError(error: unknown): boolean {
   const e = error as { code?: unknown; message?: unknown };
   if (typeof e?.code === "string" && CONNECTIVITY_ERRNO.has(e.code)) {
     return true;

apps/webapp/app/v3/mollifier/mollifierDrainerHandler.server.ts

@@ -7,6 +7,7 @@ import type {
   MollifierDrainerTerminalFailureHandler,
 } from "@trigger.dev/redis-worker";
 import { logger } from "~/services/logger.server";
+import { looksLikeConnectivityError } from "~/utils/prismaErrors";
 import { recordRunDebugLog } from "~/v3/eventRepository/index.server";
 import { PerformTaskRunAlertsService } from "~/v3/services/alerts/performTaskRunAlerts.server";
 import { startSpan } from "~/v3/tracing.server";
@@ -29,6 +30,7 @@ export function isRetryablePgError(err: unknown): boolean {
   if (msg.includes("Can't reach database server")) return true;
   if (msg.includes("Connection lost")) return true;
   if (msg.includes("ECONNRESET")) return true;
+  if (looksLikeConnectivityError(err)) return true;
   return false;
 }