temp changing pytests's setup and teardown are run to see if this will fix everything

Author: sleepyStick

test/__init__.py

@@ -861,8 +861,9 @@ def max_message_size_bytes(self):
 
 def recreate_client_context():
     global client_context
+    teardown()
     client_context = ClientContext()
-    client_context.init()
+    setup()
 
 
 class PyMongoTestCase(unittest.TestCase):
@@ -1233,6 +1234,8 @@ def tearDown(self):
 
 
 def setup():
+    global client_context
+    client_context = ClientContext()
     client_context.init()
     warnings.resetwarnings()
     warnings.simplefilter("always")

test/asynchronous/__init__.py

@@ -863,8 +863,9 @@ async def max_message_size_bytes(self):
 
 async def recreate_client_context():
     global async_client_context
+    await async_teardown()
     async_client_context = AsyncClientContext()
-    await async_client_context.init()
+    await async_setup()
 
 
 class AsyncPyMongoTestCase(unittest.IsolatedAsyncioTestCase):
@@ -1251,6 +1252,8 @@ def tearDown(self):
 
 
 async def async_setup():
+    global async_client_context
+    async_client_context = AsyncClientContext()
     await async_client_context.init()
     warnings.resetwarnings()
     warnings.simplefilter("always")

test/asynchronous/conftest.py

@@ -24,7 +24,7 @@ def event_loop_policy():
     return asyncio.get_event_loop_policy()
 
 
-@pytest_asyncio.fixture(scope="session", autouse=True)
+@pytest_asyncio.fixture(scope="module", autouse=True)
 async def test_setup_and_teardown():
     await async_setup()
     yield

test/asynchronous/test_connections_survive_primary_stepdown_spec.py

@@ -65,7 +65,7 @@ async def _setup_class(cls):
     @classmethod
     async def _tearDown_class(cls):
         await cls.client.close()
-        await recreate_client_context()
+        # await recreate_client_context()
 
     async def asyncSetUp(self):
         # Note that all ops use same write-concern as self.db (majority).

test/asynchronous/test_monitoring.py

@@ -413,7 +413,6 @@ async def test_not_primary_error(self):
         try:
             await client.pymongo_test.test.find_one_and_delete({})
         except NotPrimaryError as exc:
-            print("an error was raised")
             error = exc.errors
         started = self.listener.started_events[0]
         failed = self.listener.failed_events[0]

test/conftest.py

@@ -22,7 +22,7 @@ def event_loop_policy():
     return asyncio.get_event_loop_policy()
 
 
-@pytest.fixture(scope="session", autouse=True)
+@pytest.fixture(scope="module", autouse=True)
 def test_setup_and_teardown():
     setup()
     yield

test/test_connections_survive_primary_stepdown_spec.py

@@ -65,7 +65,7 @@ def _setup_class(cls):
     @classmethod
     def _tearDown_class(cls):
         cls.client.close()
-        recreate_client_context()
+        # recreate_client_context()
 
     def setUp(self):
         # Note that all ops use same write-concern as self.db (majority).

test/test_monitoring.py

@@ -413,7 +413,6 @@ def test_not_primary_error(self):
         try:
             client.pymongo_test.test.find_one_and_delete({})
         except NotPrimaryError as exc:
-            print("an error was raised")
             error = exc.errors
         started = self.listener.started_events[0]
         failed = self.listener.failed_events[0]