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 29f4302 commit cd19ba2Copy full SHA for cd19ba2
modules/module-postgres-storage/src/storage/batch/PostgresBucketBatch.ts
@@ -355,6 +355,10 @@ export class PostgresBucketBatch
355
COALESCE(sr.keepalive_op, 0)
356
)
357
ELSE sr.last_checkpoint
358
+ END,
359
+ snapshot_lsn = CASE
360
+ WHEN selected.can_checkpoint THEN NULL
361
+ ELSE sr.snapshot_lsn
362
END
363
FROM
364
selected
@@ -438,7 +442,6 @@ export class PostgresBucketBatch
438
442
SET
439
443
snapshot_done = TRUE,
440
444
last_keepalive_ts = ${{ type: 1184, value: new Date().toISOString() }},
441
- snapshot_lsn = NULL,
445
no_checkpoint_before = CASE
446
WHEN no_checkpoint_before IS NULL
447
OR no_checkpoint_before < ${{ type: 'varchar', value: no_checkpoint_before_lsn }} THEN ${{
0 commit comments