We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ce500a1 commit f5ec031Copy full SHA for f5ec031
modules/module-postgres/src/replication/PostgresSnapshotter.ts
@@ -344,6 +344,10 @@ export class PostgresSnapshotter {
344
}
345
346
async replicationLoop() {
347
+ if (this.queue.size == 0) {
348
+ // Special case where we start with no tables to snapshot
349
+ await this.markSnapshotDone();
350
+ }
351
while (!this.abort_signal.aborted) {
352
const table = this.queue.values().next().value;
353
if (table == null) {
0 commit comments