Skip to content

Commit 049b32a

Browse files
committed
Implement missing method for Postgres storage.
1 parent f5ec031 commit 049b32a

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

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

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -443,6 +443,16 @@ export class PostgresBucketBatch
443443
}
444444
}
445445

446+
async markTableSnapshotRequired(table: storage.SourceTable): Promise<void> {
447+
await this.db.sql`
448+
UPDATE sync_rules
449+
SET
450+
snapshot_done = FALSE
451+
WHERE
452+
id = ${{ type: 'int4', value: this.group_id }}
453+
`.execute();
454+
}
455+
446456
async markTableSnapshotDone(
447457
tables: storage.SourceTable[],
448458
no_checkpoint_before_lsn?: string

0 commit comments

Comments
 (0)