PYTHON-4941 - Fix Synchronous unified test runner being used in async…

test/asynchronous/test_auth_spec.py

@@ -25,7 +25,7 @@
 sys.path[0:0] = [""]
 
 from test import unittest
-from test.unified_format import generate_test_classes
+from test.asynchronous.unified_format import generate_test_classes
 
 from pymongo import AsyncMongoClient
 from pymongo.asynchronous.auth_oidc import OIDCCallback

test/asynchronous/test_change_stream.py

@@ -35,7 +35,7 @@
     async_client_context,
     unittest,
 )
-from test.unified_format import generate_test_classes
+from test.asynchronous.unified_format import generate_test_classes
 from test.utils import (
     AllowListEventListener,
     EventListener,

test/asynchronous/test_connection_logging.py

@@ -22,7 +22,7 @@
 sys.path[0:0] = [""]
 
 from test import unittest
-from test.unified_format import generate_test_classes
+from test.asynchronous.unified_format import generate_test_classes
 
 _IS_SYNC = False
 

test/asynchronous/test_crud_unified.py

@@ -22,7 +22,7 @@
 sys.path[0:0] = [""]
 
 from test import unittest
-from test.unified_format import generate_test_classes
+from test.asynchronous.unified_format import generate_test_classes
 
 _IS_SYNC = False
 

test/asynchronous/test_encryption.py

@@ -46,6 +46,7 @@
     unittest,
 )
 from test.asynchronous.test_bulk import AsyncBulkTestBase
+from test.asynchronous.unified_format import generate_test_classes
 from test.asynchronous.utils_spec_runner import AsyncSpecRunner
 from test.helpers import (
     AWS_CREDS,
@@ -56,7 +57,6 @@
     KMIP_CREDS,
     LOCAL_MASTER_KEY,
 )
-from test.unified_format import generate_test_classes
 from test.utils import (
     AllowListEventListener,
     OvertCommandListener,

test/asynchronous/unified_format.py

@@ -862,7 +862,7 @@ async def _clientEncryptionOperation_createDataKey(self, target, *args, **kwargs
         return await target.create_data_key(*args, **kwargs)
 
     async def _clientEncryptionOperation_getKeys(self, target, *args, **kwargs):
-        return await (await target.get_keys(*args, **kwargs)).to_list()
+        return await target.get_keys(*args, **kwargs).to_list()
 
     async def _clientEncryptionOperation_deleteKey(self, target, *args, **kwargs):
         result = await target.delete_key(*args, **kwargs)

test/unified_format.py

@@ -858,7 +858,7 @@ def _clientEncryptionOperation_createDataKey(self, target, *args, **kwargs):
         return target.create_data_key(*args, **kwargs)
 
     def _clientEncryptionOperation_getKeys(self, target, *args, **kwargs):
-        return (target.get_keys(*args, **kwargs)).to_list()
+        return target.get_keys(*args, **kwargs).to_list()
 
     def _clientEncryptionOperation_deleteKey(self, target, *args, **kwargs):
         result = target.delete_key(*args, **kwargs)