SERVER-34337 gate on transaction support when running cluster aggregation integration test

2 files changed, 17 insertions, 0 deletions

diff --git a/jstests/sharding/aggregation_currentop.js b/jstests/sharding/aggregation_currentop.js
index 73962de3f4a..1a0d4b72281 100644
--- a/jstests/sharding/aggregation_currentop.js
+++ b/jstests/sharding/aggregation_currentop.js
@@ -85,6 +85,15 @@
     createUsers(shardConn);
     createUsers(mongosConn);
 
+    // Gate this test to transaction supporting engines only as it uses txnNumber.
+    assert(shardAdminDB.auth("admin", "pwd"));
+    if (!shardAdminDB.serverStatus().storageEngine.supportsSnapshotReadConcern) {
+        jsTestLog("Do not run on storage engine that does not support transactions");
+        st.stop();
+        return;
+    }
+    shardAdminDB.logout();
+
     // Create a test database and some dummy data on rs0.
     assert(clusterAdminDB.auth("admin", "pwd"));
 
diff --git a/jstests/sharding/aggregations_in_session.js b/jstests/sharding/aggregations_in_session.js
index 6c5fcdb41be..9113358135b 100644
--- a/jstests/sharding/aggregations_in_session.js
+++ b/jstests/sharding/aggregations_in_session.js
@@ -5,6 +5,14 @@
 
     const st = new ShardingTest({shards: 2});
 
+    // Gate this test to transaction supporting engines only as it uses txnNumber.
+    let shardDB = st.rs0.getPrimary().getDB("test");
+    if (!shardDB.serverStatus().storageEngine.supportsSnapshotReadConcern) {
+        jsTestLog("Do not run on storage engine that does not support transactions");
+        st.stop();
+        return;
+    }
+
     const session = st.s0.getDB("test").getMongo().startSession();
     const mongosColl = session.getDatabase("test")[jsTestName()];