1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/exec/timeseries_write.cpp b/src/mongo/db/exec/timeseries_write.cpp
index 0493a078cc7..fe304e3b843 100644
--- a/src/mongo/db/exec/timeseries_write.cpp
+++ b/src/mongo/db/exec/timeseries_write.cpp
@@ -77,7 +77,8 @@ void TimeseriesWriteStage::_writeToTimeseriesBuckets() {
         write_ops::DeleteOpEntry deleteEntry(BSON("_id" << bucketId), false);
         write_ops::DeleteCommandRequest op(collection()->ns(), {deleteEntry});
         // TODO (SERVER-73093): Handles the write failures through retry.
-        auto result = timeseries::performAtomicWrites(opCtx(), collection(), _currentBucketRid, op);
+        auto result = timeseries::performAtomicWrites(
+            opCtx(), collection(), _currentBucketRid, op, /*fromMigrate=*/false);
     } else {
         auto timeseriesOptions = collection()->getTimeseriesOptions();
         auto metaFieldName = timeseriesOptions->getMetaField();
@@ -94,7 +95,8 @@ void TimeseriesWriteStage::_writeToTimeseriesBuckets() {
         write_ops::UpdateOpEntry updateEntry(BSON("_id" << bucketId), std::move(u));
         write_ops::UpdateCommandRequest op(collection()->ns(), {updateEntry});
         // TODO (SERVER-73093): Handles the write failures through retry.
-        auto result = timeseries::performAtomicWrites(opCtx(), collection(), _currentBucketRid, op);
+        auto result = timeseries::performAtomicWrites(
+            opCtx(), collection(), _currentBucketRid, op, /*fromMigrate=*/false);
     }
 }