PYTHON-5248 - Mark Server version 4.0 as EOL

Author: NoahStapp

.evergreen/generated_configs/tasks.yml

@@ -146,7 +146,7 @@ buildvariants:
       COMPRESSOR: zlib
   - name: compression-zstd-rhel8
     tasks:
-      - name: .test-standard !.server-4.0
+      - name: .test-standard !.server-4.2
     display_name: Compression zstd RHEL8
     run_on:
       - rhel87-small
@@ -522,13 +522,6 @@ buildvariants:
       PYTHON_BINARY: /opt/python/3.9/bin/python3
 
   # Server version tests
-  - name: mongodb-v4.0
-    tasks:
-      - name: .server-version
-    display_name: "* MongoDB v4.0"
-    run_on:
-      - rhel87-small
-    tags: [coverage_tag]
   - name: mongodb-v4.2
     tasks:
       - name: .server-version
@@ -684,11 +677,3 @@ buildvariants:
       - rhel87-small
     expansions:
       STORAGE_ENGINE: inmemory
-  - name: storage-mmapv1-rhel8
-    tasks:
-      - name: .test-standard !.sharded_cluster-auth-ssl .server-4.0
-    display_name: Storage MMAPv1 RHEL8
-    run_on:
-      - rhel87-small
-    expansions:
-      STORAGE_ENGINE: mmapv1

.evergreen/generated_configs/variants.yml

@@ -25,7 +25,6 @@
     get_task_name,
     get_variant_name,
     get_versions_from,
-    get_versions_until,
     handle_c_ext,
     write_functions_to_file,
     write_tasks_to_file,
@@ -196,7 +195,7 @@ def create_compression_variants():
     for compressor in "snappy", "zlib", "zstd":
         expansions = dict(COMPRESSOR=compressor)
         if compressor == "zstd":
-            tasks = [".test-standard !.server-4.0"]
+            tasks = [".test-standard !.server-4.2"]
         else:
             tasks = [".test-standard"]
         display_name = get_variant_name(f"Compression {compressor}", host)
@@ -249,16 +248,11 @@ def create_pyopenssl_variants():
 
 def create_storage_engine_variants():
     host = DEFAULT_HOST
-    engines = ["InMemory", "MMAPv1"]
+    engines = ["InMemory"]
     variants = []
     for engine in engines:
         expansions = dict(STORAGE_ENGINE=engine.lower())
-        if engine == engines[0]:
-            tasks = [".test-standard .standalone-noauth-nossl"]
-        else:
-            # MongoDB 4.2 drops support for MMAPv1
-            versions = get_versions_until("4.0")
-            tasks = [f".test-standard !.sharded_cluster-auth-ssl .server-{v}" for v in versions]
+        tasks = [".test-standard .standalone-noauth-nossl"]
         display_name = get_variant_name(f"Storage {engine}", host)
         variant = create_variant(tasks, display_name, host=host, expansions=expansions)
         variants.append(variant)

.evergreen/scripts/generate_config.py

@@ -21,7 +21,7 @@
 # Globals
 ##############
 
-ALL_VERSIONS = ["4.0", "4.2", "4.4", "5.0", "6.0", "7.0", "8.0", "rapid", "latest"]
+ALL_VERSIONS = ["4.2", "4.4", "5.0", "6.0", "7.0", "8.0", "rapid", "latest"]
 CPYTHONS = ["3.9", "3.10", "3.11", "3.12", "3.13"]
 PYPYS = ["pypy3.10"]
 ALL_PYTHONS = CPYTHONS + PYPYS

.evergreen/scripts/generate_config_utils.py

@@ -263,9 +263,6 @@ def _init_client(self):
                 self.server_status = {}
             else:
                 self.server_status = self.client.admin.command("serverStatus")
-                if self.storage_engine == "mmapv1":
-                    # MMAPv1 does not support retryWrites=True.
-                    self.default_client_options["retryWrites"] = False
 
             hello = self.hello
             self.sessions_enabled = "logicalSessionTimeoutMinutes" in hello
@@ -525,19 +522,6 @@ def require_data_lake(self, func):
             func=func,
         )
 
-    def require_no_mmap(self, func):
-        """Run a test only if the server is not using the MMAPv1 storage
-        engine. Only works for standalone and replica sets; tests are
-        run regardless of storage engine on sharded clusters.
-        """
-
-        def is_not_mmap():
-            if self.is_mongos:
-                return True
-            return self.storage_engine != "mmapv1"
-
-        return self._require(is_not_mmap, "Storage engine must not be MMAPv1", func=func)
-
     def require_version_min(self, *ver):
         """Run a test only if the server version is at least ``version``."""
         other_version = Version(*ver)
@@ -674,7 +658,7 @@ def require_no_serverless(self, func):
 
     def require_change_streams(self, func):
         """Run a test only if the server supports change streams."""
-        return self.require_no_mmap(self.require_no_standalone(self.require_no_serverless(func)))
+        return self.require_no_standalone(self.require_no_serverless(func))
 
     def is_topology_type(self, topologies):
         unknown = set(topologies) - {
@@ -777,8 +761,6 @@ def require_sessions(self, func):
         return self._require(lambda: self.sessions_enabled, "Sessions not supported", func=func)
 
     def supports_retryable_writes(self):
-        if self.storage_engine == "mmapv1":
-            return False
         if not self.sessions_enabled:
             return False
         return self.is_mongos or self.is_rs
@@ -792,9 +774,6 @@ def require_retryable_writes(self, func):
         )
 
     def supports_transactions(self):
-        if self.storage_engine == "mmapv1":
-            return False
-
         if self.version.at_least(4, 1, 8):
             return self.is_mongos or self.is_rs
 

test/__init__.py

@@ -263,9 +263,6 @@ async def _init_client(self):
                 self.server_status = {}
             else:
                 self.server_status = await self.client.admin.command("serverStatus")
-                if self.storage_engine == "mmapv1":
-                    # MMAPv1 does not support retryWrites=True.
-                    self.default_client_options["retryWrites"] = False
 
             hello = await self.hello
             self.sessions_enabled = "logicalSessionTimeoutMinutes" in hello
@@ -527,19 +524,6 @@ def require_data_lake(self, func):
             func=func,
         )
 
-    def require_no_mmap(self, func):
-        """Run a test only if the server is not using the MMAPv1 storage
-        engine. Only works for standalone and replica sets; tests are
-        run regardless of storage engine on sharded clusters.
-        """
-
-        def is_not_mmap():
-            if self.is_mongos:
-                return True
-            return self.storage_engine != "mmapv1"
-
-        return self._require(is_not_mmap, "Storage engine must not be MMAPv1", func=func)
-
     def require_version_min(self, *ver):
         """Run a test only if the server version is at least ``version``."""
         other_version = Version(*ver)
@@ -676,7 +660,7 @@ def require_no_serverless(self, func):
 
     def require_change_streams(self, func):
         """Run a test only if the server supports change streams."""
-        return self.require_no_mmap(self.require_no_standalone(self.require_no_serverless(func)))
+        return self.require_no_standalone(self.require_no_serverless(func))
 
     async def is_topology_type(self, topologies):
         unknown = set(topologies) - {
@@ -779,8 +763,6 @@ def require_sessions(self, func):
         return self._require(lambda: self.sessions_enabled, "Sessions not supported", func=func)
 
     def supports_retryable_writes(self):
-        if self.storage_engine == "mmapv1":
-            return False
         if not self.sessions_enabled:
             return False
         return self.is_mongos or self.is_rs
@@ -794,9 +776,6 @@ def require_retryable_writes(self, func):
         )
 
     def supports_transactions(self):
-        if self.storage_engine == "mmapv1":
-            return False
-
         if self.version.at_least(4, 1, 8):
             return self.is_mongos or self.is_rs
 

test/asynchronous/__init__.py

@@ -1600,7 +1600,6 @@ async def test_get_item(self):
     async def test_collation(self):
         await anext(self.db.test.find_raw_batches(collation=Collation("en_US")))
 
-    @async_client_context.require_no_mmap  # MMAPv1 does not support read concern
     async def test_read_concern(self):
         await self.db.get_collection("test", write_concern=WriteConcern(w="majority")).insert_one(
             {}

test/asynchronous/test_cursor.py

@@ -1162,7 +1162,6 @@ async def callback(session):
 
 class TestCausalConsistencyExamples(AsyncIntegrationTest):
     @async_client_context.require_secondaries_count(1)
-    @async_client_context.require_no_mmap
     async def test_causal_consistency(self):
         # Causal consistency examples
         client = self.client

test/asynchronous/test_examples.py

@@ -141,40 +141,10 @@ async def asyncTearDown(self) -> None:
         self.deprecation_filter.stop()
 
 
-class TestRetryableWritesMMAPv1(IgnoreDeprecationsTest):
-    knobs: client_knobs
-
-    async def asyncSetUp(self) -> None:
-        await super().asyncSetUp()
-        # Speed up the tests by decreasing the heartbeat frequency.
-        self.knobs = client_knobs(heartbeat_frequency=0.1, min_heartbeat_interval=0.1)
-        self.knobs.enable()
-        self.client = await self.async_rs_or_single_client(retryWrites=True)
-        self.db = self.client.pymongo_test
-
-    async def asyncTearDown(self) -> None:
-        self.knobs.disable()
-
-    @async_client_context.require_no_standalone
-    async def test_actionable_error_message(self):
-        if async_client_context.storage_engine != "mmapv1":
-            raise SkipTest("This cluster is not running MMAPv1")
-
-        expected_msg = (
-            "This MongoDB deployment does not support retryable "
-            "writes. Please add retryWrites=false to your "
-            "connection string."
-        )
-        for method, args, kwargs in retryable_single_statement_ops(self.db.retryable_write_test):
-            with self.assertRaisesRegex(OperationFailure, expected_msg):
-                await method(*args, **kwargs)
-
-
 class TestRetryableWrites(IgnoreDeprecationsTest):
     listener: OvertCommandListener
     knobs: client_knobs
 
-    @async_client_context.require_no_mmap
     async def asyncSetUp(self) -> None:
         await super().asyncSetUp()
         # Speed up the tests by decreasing the heartbeat frequency.
@@ -427,7 +397,6 @@ class TestWriteConcernError(AsyncIntegrationTest):
     fail_insert: dict
 
     @async_client_context.require_replica_set
-    @async_client_context.require_no_mmap
     @async_client_context.require_failCommand_fail_point
     async def asyncSetUp(self) -> None:
         await super().asyncSetUp()
@@ -599,7 +568,6 @@ async def test_returns_original_error_code(
 # TODO: Make this a real integration test where we stepdown the primary.
 class TestRetryableWritesTxnNumber(IgnoreDeprecationsTest):
     @async_client_context.require_replica_set
-    @async_client_context.require_no_mmap
     async def test_increment_transaction_id_without_sending_command(self):
         """Test that the txnNumber field is properly incremented, even when
         the first attempt fails before sending the command.

test/asynchronous/test_retryable_writes.py

@@ -1095,7 +1095,6 @@ async def test_server_not_causal(self):
             self.assertIsNone(act)
 
     @async_client_context.require_no_standalone
-    @async_client_context.require_no_mmap
     async def test_read_concern(self):
         async with self.client.start_session(causal_consistency=True) as s:
             coll = self.client.pymongo_test.test