make helpers an async file to clean up code

Author: sleepyStick

test/asynchronous/test_retryable_writes.py

@@ -27,9 +27,9 @@
     AsyncIntegrationTest,
     SkipTest,
     async_client_context,
-    client_knobs,
     unittest,
 )
+from test.asynchronous.helpers import client_knobs
 from test.utils import (
     CMAPListener,
     DeprecationFilter,

test/helpers.py

@@ -48,6 +48,8 @@
 if HAVE_SSL:
     import ssl
 
+_IS_SYNC = True
+
 # Enable debug output for uncollectable objects. PyPy does not have set_debug.
 if hasattr(gc, "set_debug"):
     gc.set_debug(
@@ -205,18 +207,10 @@ def __exit__(self, exc_type, exc_val, exc_tb):
 
     def __call__(self, func):
         def make_wrapper(f):
-            if iscoroutinefunction(f):
-
-                @wraps(f)
-                async def wrap(*args, **kwargs):
-                    with self:
-                        return await f(*args, **kwargs)
-            else:
-
-                @wraps(f)
-                def wrap(*args, **kwargs):
-                    with self:
-                        return f(*args, **kwargs)
+            @wraps(f)
+            def wrap(*args, **kwargs):
+                with self:
+                    return f(*args, **kwargs)
 
             return wrap
 

test/test_retryable_writes.py

@@ -27,9 +27,9 @@
     IntegrationTest,
     SkipTest,
     client_context,
-    client_knobs,
     unittest,
 )
+from test.helpers import client_knobs
 from test.utils import (
     CMAPListener,
     DeprecationFilter,

tools/synchro.py

@@ -162,6 +162,7 @@
 converted_tests = [
     "__init__.py",
     "conftest.py",
+    "helpers.py",
     "pymongo_mocks.py",
     "utils_spec_runner.py",
     "qcheck.py",