Move functionality to UserDb (ydb-platform#1251)

GrigoriyPA · Jan 26, 2024 · 65c46e5 · 65c46e5
1 parent 50d29ce
commit 65c46e5
Show file tree

Hide file tree

Showing 18 changed files with 1,048 additions and 863 deletions.
diff --git a/ydb/core/tx/datashard/build_distributed_erase_tx_out_rs_unit.cpp b/ydb/core/tx/datashard/build_distributed_erase_tx_out_rs_unit.cpp
@@ -103,8 +103,10 @@ class TBuildDistributedEraseTxOutRSUnit : public TExecutionUnit {
         condition->Prepare(txc.DB.GetRowScheme(tableInfo.LocalTid), 0);
 
         const auto tags = MakeTags(condition->Tags(), eraseTx->GetIndexColumnIds());
-        auto readVersion = DataShard.GetReadWriteVersions(tx).ReadVersion;
-        TDataShardUserDb userDb(DataShard, txc.DB, readVersion);
+        auto now = TAppData::TimeProvider->Now();
+        auto [readVersion, writeVersion] = DataShard.GetReadWriteVersions(tx);
+        NMiniKQL::TEngineHostCounters engineHostCounters;
+        TDataShardUserDb userDb(DataShard, txc.DB, op->GetGlobalTxId(), readVersion, writeVersion, engineHostCounters, now);
         bool pageFault = false;
 
         TDynBitMap confirmedRows;