fix(drizzle): surface connection errors in beginTransaction instead of hanging forever (#16220)

When `beginTransaction` fails to establish a database connection (e.g.
due to network issues or expired AWS IAM tokens), the function hangs
forever instead of throwing an error.

This happens because `drizzle.transaction()` rejects when the connection
fails, but the old `.catch(() => { // swallow })` silently ate the
error. Since the transaction callback never ran, `transactionReady()`
was never called, leaving the outer `await` permanently suspended.
Callers never receive an error and the operation never completes.

The fix replaces the swallowed `.catch` with one that rejects the outer
promise, so the existing `try/catch` block can log the real error and
re-throw it to callers.

## What happened in practice

In practice, this issue resulted in the job queue to randomly stop
processing jobs, if a previous cron hangs during `beginTransaction`. The
only way to get it to start processing jobs again was to restart the
node process.

---
- To see the specific tasks where the Asana app for GitHub is being
used, see below:
  - https://app.asana.com/0/0/1213983836266037

Author: AlessioGr

packages/drizzle/src/transactions/beginTransaction.ts

@@ -17,6 +17,7 @@ export const beginTransaction: BeginTransaction = async function beginTransactio
     let transaction: DrizzleTransaction
 
     let transactionReady: () => void
+    let transactionFailed: (err: unknown) => void
 
     // Await initialization here
     // Prevent race conditions where the adapter may be
@@ -44,13 +45,17 @@ export const beginTransaction: BeginTransaction = async function beginTransactio
           transactionReady()
         })
       }, options || this.transactionOptions)
-      .catch(() => {
-        // swallow
+      .catch((err) => {
+        // Connection failed before callback ran - reject instead of hanging forever
+        transactionFailed(err)
       })
 
     // Need to wait until the transaction is ready
     // before binding its `resolve` and `reject` methods below
-    await new Promise<void>((resolve) => (transactionReady = resolve))
+    await new Promise<void>((res, rej) => {
+      transactionReady = res
+      transactionFailed = rej
+    })
 
     this.sessions[id] = {
       db: transaction,

test/database/int.spec.ts

@@ -2321,6 +2321,49 @@ describe('database', () => {
         })
       }
 
+      it(
+        'should throw error when beginTransaction fails to connect (drizzle)',
+        { db: (adapter) => adapter.startsWith('postgres') || adapter === 'supabase' },
+        async () => {
+          const db = payload.db as unknown as Record<string, unknown>
+          const originalDrizzle = db.drizzle
+          try {
+            db.drizzle = {
+              transaction: () => Promise.reject(new Error('connection refused')),
+            }
+
+            await expect(() => payload.db.beginTransaction()).rejects.toThrow(/connection refused/)
+          } finally {
+            db.drizzle = originalDrizzle
+          }
+        },
+      )
+
+      it(
+        'should throw error when beginTransaction fails to connect (mongo)',
+        {
+          db: (adapter) =>
+            adapter === 'mongodb' || adapter === 'mongodb-atlas' || adapter === 'documentdb',
+        },
+        async () => {
+          const db = payload.db as unknown as Record<string, unknown>
+          const originalConnection = db.connection
+          try {
+            db.connection = {
+              getClient: () => ({
+                startSession: () => {
+                  throw new Error('connection refused')
+                },
+              }),
+            }
+
+            await expect(() => payload.db.beginTransaction()).rejects.toThrow(/connection refused/)
+          } finally {
+            db.connection = originalConnection
+          }
+        },
+      )
+
       describe('disableTransaction', () => {
         let disabledTransactionPost
         beforeAll(async () => {