use concurrent runner and add min server version

Author: blink1073

test/asynchronous/test_discovery_and_monitoring.py

@@ -496,15 +496,21 @@ async def target():
 
         # Warm the pool with 10 tasks so there are existing connections.
         tasks = []
-        for i in range(10):
-            tasks.append(asyncio.create_task(target()))
-        await asyncio.wait(tasks)
+        for _ in range(10):
+            tasks.append(ConcurrentRunner(target=target))
+        for t in tasks:
+            t.start()
+        for t in tasks:
+            t.join()
 
         # Run 100 parallel operations that contend for connections.
         tasks = []
-        for i in range(100):
-            tasks.append(asyncio.create_task(target()))
-        await asyncio.wait(tasks)
+        for _ in range(100):
+            tasks.append(ConcurrentRunner(target=target))
+        for t in tasks:
+            t.start()
+        for t in tasks:
+            t.join()
 
         # Verify there were at least 10 connection checkout failed event but no pool cleared events.
         self.assertGreater(len(listener.events_by_type(ConnectionCheckOutFailedEvent)), 10)

test/test_discovery_and_monitoring.py

@@ -490,15 +490,21 @@ def target():
 
         # Warm the pool with 10 tasks so there are existing connections.
         tasks = []
-        for i in range(10):
-            tasks.append(asyncio.create_task(target()))
-        asyncio.wait(tasks)
+        for _ in range(10):
+            tasks.append(ConcurrentRunner(target=target))
+        for t in tasks:
+            t.start()
+        for t in tasks:
+            t.join()
 
         # Run 100 parallel operations that contend for connections.
         tasks = []
-        for i in range(100):
-            tasks.append(asyncio.create_task(target()))
-        asyncio.wait(tasks)
+        for _ in range(100):
+            tasks.append(ConcurrentRunner(target=target))
+        for t in tasks:
+            t.start()
+        for t in tasks:
+            t.join()
 
         # Verify there were at least 10 connection checkout failed event but no pool cleared events.
         self.assertGreater(len(listener.events_by_type(ConnectionCheckOutFailedEvent)), 10)