fix maxconnecting test

Author: blink1073

test/asynchronous/test_pooling.py

@@ -29,6 +29,7 @@
 from pymongo.errors import AutoReconnect, ConnectionFailure, DuplicateKeyError
 from pymongo.hello import HelloCompat
 from pymongo.lock import _async_create_lock
+from pymongo.read_preferences import ReadPreference
 
 sys.path[0:0] = [""]
 
@@ -397,7 +398,8 @@ async def test_checkout_more_than_max_pool_size(self):
     async def _check_maxConnecting(
         self, client: AsyncMongoClient, backoff=False
     ) -> tuple[int, int]:
-        await client.test.test.insert_one({})
+        coll = client.test.test.with_options(read_preference=ReadPreference.PRIMARY)
+        await coll.insert_one({})
 
         pool = await async_get_pool(client)
         if backoff:
@@ -406,15 +408,15 @@ async def _check_maxConnecting(
 
         # Run 50 short running operations
         async def find_one():
-            docs.append(await client.test.test.find_one({}))
+            docs.append(await coll.find_one({}))
 
         tasks = [ConcurrentRunner(target=find_one) for _ in range(50)]
         for task in tasks:
             await task.start()
         for task in tasks:
             await task.join(10)
 
-        await client.test.test.delete_many({})
+        await coll.delete_many({})
 
         return len(docs), len(pool.conns)
 

test/test_pooling.py

@@ -29,6 +29,7 @@
 from pymongo.errors import AutoReconnect, ConnectionFailure, DuplicateKeyError
 from pymongo.hello import HelloCompat
 from pymongo.lock import _create_lock
+from pymongo.read_preferences import ReadPreference
 
 sys.path[0:0] = [""]
 
@@ -395,7 +396,8 @@ def test_checkout_more_than_max_pool_size(self):
         pool.close()
 
     def _check_maxConnecting(self, client: MongoClient, backoff=False) -> tuple[int, int]:
-        client.test.test.insert_one({})
+        coll = client.test.test.with_options(read_preference=ReadPreference.PRIMARY)
+        coll.insert_one({})
 
         pool = get_pool(client)
         if backoff:
@@ -404,15 +406,15 @@ def _check_maxConnecting(self, client: MongoClient, backoff=False) -> tuple[int,
 
         # Run 50 short running operations
         def find_one():
-            docs.append(client.test.test.find_one({}))
+            docs.append(coll.find_one({}))
 
         tasks = [ConcurrentRunner(target=find_one) for _ in range(50)]
         for task in tasks:
             task.start()
         for task in tasks:
             task.join(10)
 
-        client.test.test.delete_many({})
+        coll.delete_many({})
 
         return len(docs), len(pool.conns)