fix assert

Signed-off-by: Vladislav Oleshko <vlad@dragonflydb.io>

Author: dranikpg

src/server/db_slice.h

@@ -8,6 +8,7 @@
 #include <absl/container/flat_hash_set.h>
 
 #include <atomic>
+#include <ranges>
 
 #include "common/string_or_view.h"
 #include "core/mi_memory_resource.h"
@@ -401,6 +402,10 @@ class DbSlice {
     return !change_cb_.empty();
   }
 
+  auto SnapshotVersions() const {
+    return change_cb_ | std::views::keys;
+  }
+
   // Call registered callbacks with version less than upper_bound.
   void FlushChangeToEarlierCallbacks(DbIndex db_ind, Iterator it, uint64_t upper_bound);
 

src/server/serializer_base.cc

@@ -167,7 +167,11 @@ bool SerializerBase::ProcessBucketInternal(DbIndex db_index, PrimeTable::bucket_
   stats_.buckets_on_change += unsigned(on_update);
 
   FinishBucketIteration(it.bucket_address());
-  DCHECK_EQ(it.GetVersion(), snapshot_version_);  // No parallel version changes while serializing
+
+  // Assert the version is equal to a snapshot version so no other modifications have happened
+  DCHECK_GE(it.GetVersion(), snapshot_version_);
+  auto current_snapshots = db_slice_->SnapshotVersions();
+  DCHECK(std::ranges::find(current_snapshots, snapshot_version_) != current_snapshots.end());
 
   if (EngineShard::tlocal()->tiered_storage() != nullptr)
     ProcessDelayedEntries(false, on_update ? it.bucket_address() : 0, base_cntx_);