return type fixes

Author: blink1073

pymongo/asynchronous/collection.py

@@ -2786,7 +2786,7 @@ async def inner(
             )
             return [index["name"] for index in resp["indexesCreated"]]
 
-        return self.database.client._retryable_write(
+        return await self.database.client._retryable_write(
             False, inner, session, _Op.CREATE_SEARCH_INDEXES
         )
 
@@ -2828,7 +2828,7 @@ async def inner(
                 session=session,
             )
 
-        return self.database.client._retryable_write(False, inner, session, _Op.DROP_SEARCH_INDEXES)
+        await self.database.client._retryable_write(False, inner, session, _Op.DROP_SEARCH_INDEXES)
 
     async def update_search_index(
         self,
@@ -2870,7 +2870,7 @@ async def inner(
                 session=session,
             )
 
-        return self.database.client._retryable_write(False, inner, session, _Op.UPDATE_SEARCH_INDEX)
+        await self.database.client._retryable_write(False, inner, session, _Op.UPDATE_SEARCH_INDEX)
 
     async def options(
         self,
@@ -3165,7 +3165,7 @@ async def inner(
                 client=client,
             )
 
-        return client._retryable_write(False, inner, session, _Op.RENAME)
+        return await client._retryable_write(False, inner, session, _Op.RENAME)
 
     async def distinct(
         self,

pymongo/asynchronous/database.py

@@ -1060,7 +1060,7 @@ async def inner(
                     raise InvalidOperation("Command does not return a cursor.")
 
             return await self.client._retryable_read(
-                inner, read_preference, tmp_session, command_name, False
+                inner, read_preference, tmp_session, command_name, None, False
             )
 
     async def _retryable_read_command(

pymongo/asynchronous/mongo_client.py

@@ -2444,7 +2444,7 @@ async def drop_database(
                 f"name_or_database must be an instance of str or a AsyncDatabase, not {type(name)}"
             )
 
-        return await self[name].command(
+        await self[name].command(
             {"dropDatabase": 1, "comment": comment},
             read_preference=ReadPreference.PRIMARY,
             write_concern=self._write_concern_for(session),

pymongo/synchronous/collection.py

@@ -2823,7 +2823,7 @@ def inner(
                 session=session,
             )
 
-        return self.database.client._retryable_write(False, inner, session, _Op.DROP_SEARCH_INDEXES)
+        self.database.client._retryable_write(False, inner, session, _Op.DROP_SEARCH_INDEXES)
 
     def update_search_index(
         self,
@@ -2865,7 +2865,7 @@ def inner(
                 session=session,
             )
 
-        return self.database.client._retryable_write(False, inner, session, _Op.UPDATE_SEARCH_INDEX)
+        self.database.client._retryable_write(False, inner, session, _Op.UPDATE_SEARCH_INDEX)
 
     def options(
         self,

pymongo/synchronous/database.py

@@ -1060,7 +1060,7 @@ def inner(
                     raise InvalidOperation("Command does not return a cursor.")
 
             return self.client._retryable_read(
-                inner, read_preference, tmp_session, command_name, False
+                inner, read_preference, tmp_session, command_name, None, False
             )
 
     def _retryable_read_command(

pymongo/synchronous/mongo_client.py

@@ -2434,7 +2434,7 @@ def drop_database(
                 f"name_or_database must be an instance of str or a Database, not {type(name)}"
             )
 
-        return self[name].command(
+        self[name].command(
             {"dropDatabase": 1, "comment": comment},
             read_preference=ReadPreference.PRIMARY,
             write_concern=self._write_concern_for(session),