PYTHON-4533 - Fix failing async tests (#1739)

Author: NoahStapp

test/asynchronous/test_cursor.py

@@ -129,7 +129,7 @@ async def test_add_remove_option_exhaust(self):
         # Exhaust - which mongos doesn't support
         if async_client_context.is_mongos:
             with self.assertRaises(InvalidOperation):
-                self.db.test.find(cursor_type=CursorType.EXHAUST)
+                await anext(self.db.test.find(cursor_type=CursorType.EXHAUST))
         else:
             cursor = self.db.test.find(cursor_type=CursorType.EXHAUST)
             self.assertEqual(64, cursor._query_flags)

test/asynchronous/test_transactions.py

@@ -192,7 +192,7 @@ async def test_unpin_for_next_transaction(self):
             addresses = set()
             for _ in range(UNPIN_TEST_MAX_ATTEMPTS):
                 async with await s.start_transaction():
-                    cursor = await coll.find({}, session=s)
+                    cursor = coll.find({}, session=s)
                     self.assertTrue(await anext(cursor))
                     addresses.add(cursor.address)
                 # Break early if we can.
@@ -219,7 +219,7 @@ async def test_unpin_for_non_transaction_operation(self):
 
             addresses = set()
             for _ in range(UNPIN_TEST_MAX_ATTEMPTS):
-                cursor = await coll.find({}, session=s)
+                cursor = coll.find({}, session=s)
                 self.assertTrue(await anext(cursor))
                 addresses.add(cursor.address)
                 # Break early if we can.

test/test_cursor.py

@@ -129,7 +129,7 @@ def test_add_remove_option_exhaust(self):
         # Exhaust - which mongos doesn't support
         if client_context.is_mongos:
             with self.assertRaises(InvalidOperation):
-                self.db.test.find(cursor_type=CursorType.EXHAUST)
+                next(self.db.test.find(cursor_type=CursorType.EXHAUST))
         else:
             cursor = self.db.test.find(cursor_type=CursorType.EXHAUST)
             self.assertEqual(64, cursor._query_flags)