Merge branch 'main' into dependabot/pip/flake8-7.2.0

Author: auvipy

kombu/transport/mongodb.py

@@ -305,7 +305,9 @@ def _parse_uri(self, scheme='mongodb://'):
 
         port = client.port if client.port else self.default_port
 
-        parsed = uri_parser.parse_uri(hostname, port)
+        # We disable validating and normalization parameters here,
+        # because pymongo will validate and normalize parameters later in __init__ of MongoClient
+        parsed = uri_parser.parse_uri(hostname, port, validate=False)
 
         dbname = parsed['database'] or client.virtual_host
 

t/unit/transport/test_mongodb.py

@@ -116,6 +116,18 @@ def test_correct_readpreference(self):
         hostname, dbname, options = channel._parse_uri()
         assert options['readpreference'] == 'nearest'
 
+    def test_normalizes_params_from_uri_only_once(self):
+        channel = _create_mock_connection('mongodb://localhost/?serverselectiontimeoutms=1000').default_channel
+
+        def server_info(self):
+            return {'version': '3.6.0-rc'}
+
+        with patch.object(pymongo.MongoClient, 'server_info', server_info):
+            database = channel._open()
+
+        client_options = database.client.options
+        assert client_options.server_selection_timeout == 1.0
+
 
 class BaseMongoDBChannelCase: