Workaround for tests.

Author: rkistner

modules/module-postgres/test/src/wal_stream.test.ts

@@ -381,7 +381,17 @@ bucket_definitions:
       // The error is handled on a higher level, which triggers
       // creating a new replication slot.
       await expect(async () => {
-        await context.replicateSnapshot();
+        try {
+          await context.replicateSnapshot();
+        } catch (e) {
+          // replicateSnapshot can have a ReplicationAbortedError(cause: MissingReplicationSlotError).
+          // This is specific to tests - real replication will get the MissingReplicationSlotError directly.
+          if (e?.cause) {
+            throw e.cause;
+          } else {
+            throw e;
+          }
+        }
       }).rejects.toThrowError(MissingReplicationSlotError);
     }
   });