add ignores

Author: blink1073

pyproject.toml

@@ -144,7 +144,7 @@ disallow_any_generics = true
 
 [[tool.mypy.overrides]]
 module = ["test.*"]
-disable_error_code = ["type-arg", "no-untyped-def", "no-untyped-call", "untyped-decorator"]
+disable_error_code = ["type-arg", "no-untyped-def", "no-untyped-call"]
 
 [[tool.mypy.overrides]]
 module = ["service_identity.*"]

test/__init__.py

@@ -482,7 +482,7 @@ def create_user(self, dbname, user, pwd=None, roles=None, **kwargs):
     def drop_user(self, dbname, user):
         self.client[dbname].command("dropUser", user, writeConcern={"w": self.w})
 
-    def require_connection(self, func):
+    def require_connection(self, func: Any) -> Any:
         """Run a test only if we can connect to MongoDB."""
         return self._require(
             lambda: True,  # _require checks if we're connected
@@ -552,7 +552,7 @@ def require_no_fips(self, func):
             lambda: not self.fips_enabled, "Test cannot run on a FIPS-enabled host", func=func
         )
 
-    def require_replica_set(self, func):
+    def require_replica_set(self, func: Any) -> Any:
         """Run a test only if the client is connected to a replica set."""
         return self._require(lambda: self.is_rs, "Not connected to a replica set", func=func)
 
@@ -687,7 +687,7 @@ def require_test_commands(self, func):
             lambda: self.test_commands_enabled, "Test commands must be enabled", func=func
         )
 
-    def require_failCommand_fail_point(self, func):
+    def require_failCommand_fail_point(self, func: Any) -> Any:
         """Run a test only if the server supports the failCommand fail
         point.
         """

test/asynchronous/__init__.py

@@ -482,7 +482,7 @@ async def create_user(self, dbname, user, pwd=None, roles=None, **kwargs):
     async def drop_user(self, dbname, user):
         await self.client[dbname].command("dropUser", user, writeConcern={"w": self.w})
 
-    def require_connection(self, func):
+    def require_connection(self, func: Any) -> Any:
         """Run a test only if we can connect to MongoDB."""
         return self._require(
             lambda: True,  # _require checks if we're connected
@@ -552,7 +552,7 @@ def require_no_fips(self, func):
             lambda: not self.fips_enabled, "Test cannot run on a FIPS-enabled host", func=func
         )
 
-    def require_replica_set(self, func):
+    def require_replica_set(self, func: Any) -> Any:
         """Run a test only if the client is connected to a replica set."""
         return self._require(lambda: self.is_rs, "Not connected to a replica set", func=func)
 
@@ -687,7 +687,7 @@ def require_test_commands(self, func):
             lambda: self.test_commands_enabled, "Test commands must be enabled", func=func
         )
 
-    def require_failCommand_fail_point(self, func):
+    def require_failCommand_fail_point(self, func: Any) -> Any:
         """Run a test only if the server supports the failCommand fail
         point.
         """

test/asynchronous/test_change_stream.py

@@ -771,8 +771,8 @@ async def test_split_large_change(self):
 class TestClusterAsyncChangeStream(TestAsyncChangeStreamBase, APITestsMixin):
     dbs: list
 
-    @async_client_context.require_version_min(4, 2, 0)
-    @async_client_context.require_change_streams
+    @async_client_context.require_version_min(4, 2, 0)  # type:ignore[untyped-decorator]
+    @async_client_context.require_change_streams  # type:ignore[untyped-decorator]
     async def asyncSetUp(self) -> None:
         await super().asyncSetUp()
         self.dbs = [self.db, self.client.pymongo_test_2]
@@ -831,8 +831,8 @@ async def test_full_pipeline(self):
 
 
 class TestAsyncDatabaseAsyncChangeStream(TestAsyncChangeStreamBase, APITestsMixin):
-    @async_client_context.require_version_min(4, 2, 0)
-    @async_client_context.require_change_streams
+    @async_client_context.require_version_min(4, 2, 0)  # type:ignore[untyped-decorator]
+    @async_client_context.require_change_streams  # type:ignore[untyped-decorator]
     async def asyncSetUp(self) -> None:
         await super().asyncSetUp()
 

test/asynchronous/test_encryption.py

@@ -233,7 +233,7 @@ class AsyncEncryptionIntegrationTest(AsyncIntegrationTest):
     """Base class for encryption integration tests."""
 
     @unittest.skipUnless(_HAVE_PYMONGOCRYPT, "pymongocrypt is not installed")
-    @async_client_context.require_version_min(4, 2, -1)
+    @async_client_context.require_version_min(4, 2, -1)  # type:ignore[untyped-decorator]
     async def asyncSetUp(self) -> None:
         await super().asyncSetUp()
 

test/test_change_stream.py

@@ -757,8 +757,8 @@ def test_split_large_change(self):
 class TestClusterChangeStream(TestChangeStreamBase, APITestsMixin):
     dbs: list
 
-    @client_context.require_version_min(4, 2, 0)
-    @client_context.require_change_streams
+    @client_context.require_version_min(4, 2, 0)  # type:ignore[untyped-decorator]
+    @client_context.require_change_streams  # type:ignore[untyped-decorator]
     def setUp(self) -> None:
         super().setUp()
         self.dbs = [self.db, self.client.pymongo_test_2]
@@ -817,8 +817,8 @@ def test_full_pipeline(self):
 
 
 class TestDatabaseChangeStream(TestChangeStreamBase, APITestsMixin):
-    @client_context.require_version_min(4, 2, 0)
-    @client_context.require_change_streams
+    @client_context.require_version_min(4, 2, 0)  # type:ignore[untyped-decorator]
+    @client_context.require_change_streams  # type:ignore[untyped-decorator]
     def setUp(self) -> None:
         super().setUp()
 

test/test_encryption.py

@@ -233,7 +233,7 @@ class EncryptionIntegrationTest(IntegrationTest):
     """Base class for encryption integration tests."""
 
     @unittest.skipUnless(_HAVE_PYMONGOCRYPT, "pymongocrypt is not installed")
-    @client_context.require_version_min(4, 2, -1)
+    @client_context.require_version_min(4, 2, -1)  # type:ignore[untyped-decorator]
     def setUp(self) -> None:
         super().setUp()