Revert "SERVER-61666 Fix migration for txns before startApplying"

This reverts commit ea6a59377c01ed48157557aaaae0bd8191b7fa4e.

1 files changed, 2 insertions, 8 deletions

diff --git a/src/mongo/db/repl/tenant_oplog_batcher.cpp b/src/mongo/db/repl/tenant_oplog_batcher.cpp
index c7a3bf3c87b..e0d7539fcf6 100644
--- a/src/mongo/db/repl/tenant_oplog_batcher.cpp
+++ b/src/mongo/db/repl/tenant_oplog_batcher.cpp
@@ -42,13 +42,11 @@ namespace repl {
 TenantOplogBatcher::TenantOplogBatcher(const std::string& tenantId,
                                        RandomAccessOplogBuffer* oplogBuffer,
                                        std::shared_ptr<executor::TaskExecutor> executor,
-                                       Timestamp resumeBatchingTs,
-                                       OpTime beginApplyingAfterOpTime)
+                                       Timestamp resumeBatchingTs)
     : AbstractAsyncComponent(executor.get(), std::string("TenantOplogBatcher_") + tenantId),
       _oplogBuffer(oplogBuffer),
       _executor(executor),
-      _resumeBatchingTs(resumeBatchingTs),
-      _beginApplyingAfterOpTime(beginApplyingAfterOpTime) {}
+      _resumeBatchingTs(resumeBatchingTs) {}
 
 TenantOplogBatcher::~TenantOplogBatcher() {
     shutdown();
@@ -64,10 +62,6 @@ void TenantOplogBatcher::_pushEntry(OperationContext* opCtx,
             !op.isPreparedCommit() &&
                 (op.getCommandType() != OplogEntry::CommandType::kApplyOps || !op.shouldPrepare()));
     if (op.isTerminalApplyOps()) {
-        if (op.getOpTime() <= _beginApplyingAfterOpTime) {
-            // Fetched for the sake of retryable commitTransaction, don't need to apply.
-            return;
-        }
         // All applyOps entries are expanded and the expansions put in the batch expansion array.
         // The original applyOps is kept in the batch ops array.
         // This applies to both multi-document transactions and atomic applyOps.