Skip to content

Commit 0fb42f9

Browse files
committed
Fix results of markTableSnapshotDone.
1 parent 5c18559 commit 0fb42f9

File tree

1 file changed

+2
-11
lines changed

1 file changed

+2
-11
lines changed

modules/module-postgres-storage/src/storage/batch/PostgresBucketBatch.ts

Lines changed: 2 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -571,17 +571,8 @@ export class PostgresBucketBatch
571571
}
572572
});
573573
return tables.map((table) => {
574-
const copy = new storage.SourceTable({
575-
id: table.id,
576-
connectionTag: table.connectionTag,
577-
objectId: table.objectId,
578-
schema: table.schema,
579-
name: table.name,
580-
replicaIdColumns: table.replicaIdColumns,
581-
snapshotComplete: table.snapshotComplete
582-
});
583-
copy.syncData = table.syncData;
584-
copy.syncParameters = table.syncParameters;
574+
const copy = table.clone();
575+
copy.snapshotComplete = true;
585576
return copy;
586577
});
587578
}

0 commit comments

Comments
 (0)