Cleanup

Author: NoahStapp

pymongo/asynchronous/bulk.py

@@ -240,7 +240,6 @@ async def write_command(
         client: AsyncMongoClient,
     ) -> dict[str, Any]:
         """A proxy for SocketInfo.write_command that handles event publishing."""
-
         cmd[bwc.field] = docs
         if _COMMAND_LOGGER.isEnabledFor(logging.DEBUG):
             _debug_log(
@@ -325,7 +324,6 @@ async def unack_write(
         client: AsyncMongoClient,
     ) -> Optional[Mapping[str, Any]]:
         """A proxy for AsyncConnection.unack_write that handles event publishing."""
-
         if _COMMAND_LOGGER.isEnabledFor(logging.DEBUG):
             _debug_log(
                 _COMMAND_LOGGER,

pymongo/asynchronous/database.py

@@ -125,9 +125,7 @@ def __init__(
             raise TypeError("name must be an instance of str")
 
         if not isinstance(client, AsyncMongoClient):
-            raise TypeError(
-                f"AsyncMongoClient required but {client} is an instance of {type(client)}"
-            )
+            raise TypeError(f"AsyncMongoClient required but given {type(client)}")
 
         if name != "$external":
             _check_name(name)

pymongo/asynchronous/encryption.py

@@ -598,9 +598,7 @@ def __init__(
             raise TypeError("codec_options must be an instance of bson.codec_options.CodecOptions")
 
         if not isinstance(key_vault_client, AsyncMongoClient):
-            raise TypeError(
-                f"AsyncMongoClient required but {key_vault_client} is an instance of {type(key_vault_client)}"
-            )
+            raise TypeError(f"AsyncMongoClient required but given {type(key_vault_client)}")
 
         self._kms_providers = kms_providers
         self._key_vault_namespace = key_vault_namespace

pymongo/asynchronous/mongo_client.py

@@ -2420,9 +2420,7 @@ def __init__(
         self, client: AsyncMongoClient, server: Server, session: Optional[AsyncClientSession]
     ):
         if not isinstance(client, AsyncMongoClient):
-            raise TypeError(
-                f"AsyncMongoClient required but {client} is an instance of {type(client)}"
-            )
+            raise TypeError(f"AsyncMongoClient required but given {type(client)}")
 
         self.client = client
         self.server_address = server.description.address

pymongo/asynchronous/server.py

@@ -157,7 +157,6 @@ async def run_operation(
         :param unpack_res: A callable that decodes the wire protocol response.
         :param client: An AsyncMongoClient instance.
         """
-
         assert listeners is not None
 
         publish = listeners.enabled_for_commands

pymongo/synchronous/bulk.py

@@ -240,7 +240,6 @@ def write_command(
         client: MongoClient,
     ) -> dict[str, Any]:
         """A proxy for SocketInfo.write_command that handles event publishing."""
-
         cmd[bwc.field] = docs
         if _COMMAND_LOGGER.isEnabledFor(logging.DEBUG):
             _debug_log(
@@ -325,7 +324,6 @@ def unack_write(
         client: MongoClient,
     ) -> Optional[Mapping[str, Any]]:
         """A proxy for Connection.unack_write that handles event publishing."""
-
         if _COMMAND_LOGGER.isEnabledFor(logging.DEBUG):
             _debug_log(
                 _COMMAND_LOGGER,

pymongo/synchronous/database.py

@@ -125,7 +125,7 @@ def __init__(
             raise TypeError("name must be an instance of str")
 
         if not isinstance(client, MongoClient):
-            raise TypeError(f"MongoClient required but {client} is an instance of {type(client)}")
+            raise TypeError(f"MongoClient required but given {type(client)}")
 
         if name != "$external":
             _check_name(name)

pymongo/synchronous/encryption.py

@@ -596,9 +596,7 @@ def __init__(
             raise TypeError("codec_options must be an instance of bson.codec_options.CodecOptions")
 
         if not isinstance(key_vault_client, MongoClient):
-            raise TypeError(
-                f"MongoClient required but {key_vault_client} is an instance of {type(key_vault_client)}"
-            )
+            raise TypeError(f"MongoClient required but given {type(key_vault_client)}")
 
         self._kms_providers = kms_providers
         self._key_vault_namespace = key_vault_namespace

pymongo/synchronous/mongo_client.py

@@ -2407,7 +2407,7 @@ class _MongoClientErrorHandler:
 
     def __init__(self, client: MongoClient, server: Server, session: Optional[ClientSession]):
         if not isinstance(client, MongoClient):
-            raise TypeError(f"MongoClient required but {client} is an instance of {type(client)}")
+            raise TypeError(f"MongoClient required but given {type(client)}")
 
         self.client = client
         self.server_address = server.description.address

pymongo/synchronous/server.py

@@ -157,7 +157,6 @@ def run_operation(
         :param unpack_res: A callable that decodes the wire protocol response.
         :param client: A MongoClient instance.
         """
-
         assert listeners is not None
 
         publish = listeners.enabled_for_commands