summaryrefslogtreecommitdiff
path: root/jstests/replsets/tenant_migration_shard_merge_recipient_fetches_retryable_writes.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/tenant_migration_shard_merge_recipient_fetches_retryable_writes.js')
-rw-r--r--jstests/replsets/tenant_migration_shard_merge_recipient_fetches_retryable_writes.js65
1 files changed, 0 insertions, 65 deletions
diff --git a/jstests/replsets/tenant_migration_shard_merge_recipient_fetches_retryable_writes.js b/jstests/replsets/tenant_migration_shard_merge_recipient_fetches_retryable_writes.js
deleted file mode 100644
index 0c6712f7fc2..00000000000
--- a/jstests/replsets/tenant_migration_shard_merge_recipient_fetches_retryable_writes.js
+++ /dev/null
@@ -1,65 +0,0 @@
-/**
- * Tests that the shard merge recipient correctly fetches retryable writes.
- *
- * @tags: [
- * incompatible_with_macos,
- * incompatible_with_windows_tls,
- * featureFlagShardMerge,
- * requires_majority_read_concern,
- * requires_persistence,
- * serverless,
- * ]
- */
-(function() {
-"use strict";
-
-load("jstests/replsets/libs/tenant_migration_test.js");
-load("jstests/libs/uuid_util.js"); // For extractUUIDFromObject().
-
-const kParams = {
- ttlMonitorSleepSecs: 1,
-};
-
-const tenantMigrationTest = new TenantMigrationTest({
- name: jsTestName(),
- sharedOptions: {nodes: 1, setParameter: kParams},
- quickGarbageCollection: true
-});
-
-const kTenantId = "testTenantId";
-const tenantDB = tenantMigrationTest.tenantDB(kTenantId, "database");
-
-const donorRst = tenantMigrationTest.getDonorRst();
-const donorPrimary = tenantMigrationTest.getDonorPrimary();
-const recipientPrimary = tenantMigrationTest.getRecipientPrimary();
-
-jsTestLog("Run retryable write prior to the migration");
-
-const lsid = UUID();
-const cmd = {
- insert: "collection",
- documents: [{_id: 1}, {_id: 2}],
- ordered: false,
- lsid: {id: lsid},
- txnNumber: NumberLong(123),
-};
-
-assert.commandWorked(donorPrimary.getDB(tenantDB).runCommand(cmd));
-assert.eq(2, donorPrimary.getDB(tenantDB).collection.find().itcount());
-
-const migrationId = UUID();
-const migrationOpts = {
- migrationIdString: extractUUIDFromObject(migrationId),
- tenantId: kTenantId,
-};
-
-jsTestLog(`Starting migration: ${tojson(migrationOpts)}`);
-TenantMigrationTest.assertCommitted(tenantMigrationTest.runMigration(migrationOpts));
-
-const {ok, n} = assert.commandWorked(recipientPrimary.getDB(tenantDB).runCommand(cmd));
-assert.eq(1, ok);
-assert.eq(2, n);
-assert.eq(2, recipientPrimary.getDB(tenantDB).collection.find().itcount());
-
-tenantMigrationTest.stop();
-})();