fix handling of option

Author: blink1073

test/asynchronous/unified_format.py

@@ -330,11 +330,11 @@ async def _create_entity(self, entity_spec, uri=None):
             client = await self.test.async_rs_or_single_client(**kwargs)
             await client.aconnect()
             # Wait for pool to be populated.
-            if "awaitMinPoolSize" in spec:
+            if "awaitMinPoolSizeMS" in spec:
                 pool = await async_get_pool(client)
                 t0 = time.monotonic()
                 while True:
-                    if (time.monotonic() - t0) > spec["awaitMinPoolSize"] * 1000:
+                    if (time.monotonic() - t0) > spec["awaitMinPoolSizeMS"] * 1000:
                         raise ValueError("Test timed out during awaitMinPoolSize")
                     async with pool.lock:
                         if len(pool.conns) + pool.active_sockets >= pool.opts.min_pool_size:
@@ -1562,7 +1562,7 @@ async def test_case(self):
                 if re.search(fail_pattern, description):
                     test_method = unittest.expectedFailure(test_method)
                     break
-
+            print(test_name)
             setattr(cls, test_name, test_method)
 
 

test/unified_format.py

@@ -329,11 +329,11 @@ def _create_entity(self, entity_spec, uri=None):
             client = self.test.rs_or_single_client(**kwargs)
             client._connect()
             # Wait for pool to be populated.
-            if "awaitMinPoolSize" in spec:
+            if "awaitMinPoolSizeMS" in spec:
                 pool = get_pool(client)
                 t0 = time.monotonic()
                 while True:
-                    if (time.monotonic() - t0) > spec["awaitMinPoolSize"] * 1000:
+                    if (time.monotonic() - t0) > spec["awaitMinPoolSizeMS"] * 1000:
                         raise ValueError("Test timed out during awaitMinPoolSize")
                     with pool.lock:
                         if len(pool.conns) + pool.active_sockets >= pool.opts.min_pool_size:
@@ -1547,7 +1547,7 @@ def test_case(self):
                 if re.search(fail_pattern, description):
                     test_method = unittest.expectedFailure(test_method)
                     break
-
+            print(test_name)
             setattr(cls, test_name, test_method)