PYTHON-4641 Fix failure in async version of client bulk CSOT test (#1790)

Author: shruti-sridhar

test/asynchronous/test_client_bulk_write.py

@@ -523,7 +523,7 @@ async def test_returns_error_if_auto_encryption_configured(self):
 
 
 # https://github.com/mongodb/specifications/blob/master/source/client-side-operations-timeout/tests/README.md#11-multi-batch-bulkwrites
-class TestClientBulkWriteTimeout(AsyncIntegrationTest):
+class TestClientBulkWriteCSOT(AsyncIntegrationTest):
     async def asyncSetUp(self):
         self.max_write_batch_size = await async_client_context.max_write_batch_size
         self.max_bson_object_size = await async_client_context.max_bson_size
@@ -567,6 +567,7 @@ async def test_timeout_in_multi_batch_bulk_write(self):
                 w="majority",
             )
             self.addAsyncCleanup(client.aclose)
+            await client.admin.command("ping")  # Init the client first.
             with self.assertRaises(ClientBulkWriteException) as context:
                 await client.bulk_write(models=models)
             self.assertIsInstance(context.exception.error, NetworkTimeout)

test/test_client_bulk_write.py

@@ -523,7 +523,7 @@ def test_returns_error_if_auto_encryption_configured(self):
 
 
 # https://github.com/mongodb/specifications/blob/master/source/client-side-operations-timeout/tests/README.md#11-multi-batch-bulkwrites
-class TestClientBulkWriteTimeout(IntegrationTest):
+class TestClientBulkWriteCSOT(IntegrationTest):
     def setUp(self):
         self.max_write_batch_size = client_context.max_write_batch_size
         self.max_bson_object_size = client_context.max_bson_size
@@ -567,6 +567,7 @@ def test_timeout_in_multi_batch_bulk_write(self):
                 w="majority",
             )
             self.addCleanup(client.close)
+            client.admin.command("ping")  # Init the client first.
             with self.assertRaises(ClientBulkWriteException) as context:
                 client.bulk_write(models=models)
             self.assertIsInstance(context.exception.error, NetworkTimeout)