diff --git a/internal/services/configstore/readdb/readdb.go b/internal/services/configstore/readdb/readdb.go index 6095298..098e1b5 100644 --- a/internal/services/configstore/readdb/readdb.go +++ b/internal/services/configstore/readdb/readdb.go @@ -188,6 +188,16 @@ func (r *ReadDB) SyncFromDump() (string, error) { } } + err = r.rdb.Do(func(tx *db.Tx) error { + if err := r.insertCommittedWalSequence(tx, dumpIndex.WalSequence); err != nil { + return err + } + return nil + }) + if err != nil { + return "", err + } + return dumpIndex.WalSequence, nil } diff --git a/internal/services/runservice/readdb/readdb.go b/internal/services/runservice/readdb/readdb.go index 07ab217..4f98696 100644 --- a/internal/services/runservice/readdb/readdb.go +++ b/internal/services/runservice/readdb/readdb.go @@ -702,6 +702,16 @@ func (r *ReadDB) SyncFromDump() (string, error) { } } + err = r.rdb.Do(func(tx *db.Tx) error { + if err := r.insertCommittedWalSequenceOST(tx, dumpIndex.WalSequence); err != nil { + return err + } + return nil + }) + if err != nil { + return "", err + } + return dumpIndex.WalSequence, nil }