PYTHON-4763 Migrate test_change_stream.py to async

test/test_change_stream.py

@@ -50,6 +50,8 @@
 from pymongo.synchronous.command_cursor import CommandCursor
 from pymongo.write_concern import WriteConcern
 
+_IS_SYNC = True
+
 
 class TestChangeStreamBase(IntegrationTest):
     RUN_ON_LOAD_BALANCER = True
@@ -310,7 +312,7 @@ def _test_next_blocks(self, change_stream):
     @no_type_check
     def test_next_blocks(self):
         """Test that next blocks until a change is readable"""
-        # Use a short await time to speed up the test.
+        # Use a short time to speed up the test.
         with self.change_stream(max_await_time_ms=250) as change_stream:
             self._test_next_blocks(change_stream)
 
@@ -325,7 +327,7 @@ def test_aggregate_cursor_blocks(self):
     @no_type_check
     def test_concurrent_close(self):
         """Ensure a ChangeStream can be closed from another thread."""
-        # Use a short await time to speed up the test.
+        # Use a short time to speed up the test.
         with self.change_stream(max_await_time_ms=250) as change_stream:
 
             def iterate_cursor():

tools/synchro.py

@@ -164,6 +164,7 @@
     "test_auth.py",
     "test_auth_spec.py",
     "test_bulk.py",
+    "test_change_stream.py",
     "test_client.py",
     "test_client_bulk_write.py",
     "test_collection.py",