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 be3390a commit fcd539dCopy full SHA for fcd539d
modules/module-mongodb-storage/src/storage/implementation/MongoBucketBatch.ts
@@ -817,6 +817,16 @@ export class MongoBucketBatch
817
return false;
818
}
819
820
+ if (this.persisted_op == null) {
821
+ // FIXME: Double-check the logic here, and avoid the lookup
822
+ const doc = await this.db.sync_rules.findOne({
823
+ _id: this.group_id
824
+ });
825
+ if (doc?.keepalive_op != null) {
826
+ this.persisted_op = BigInt(doc!.keepalive_op);
827
+ }
828
829
+
830
if (this.persisted_op != null) {
831
// The commit may have been skipped due to "no_checkpoint_before_lsn".
832
// Apply it now if relevant
0 commit comments