Method inner

pymongo/asynchronous/database.py:935–951

(
            session: Optional[AsyncClientSession],
            _server: Server,
            conn: AsyncConnection,
            read_preference: _ServerMode,
        )

            read_preference = (session and session._txn_read_preference()) or ReadPreference.PRIMARY

        async def inner(
            session: Optional[AsyncClientSession],
            _server: Server,
            conn: AsyncConnection,
            read_preference: _ServerMode,
        ) -> Union[dict[str, Any], _CodecDocumentType]:
            return await self._command(
                conn,
                command,
                value,
                check,
                allowable_errors,
                read_preference,
                opts,  # type: ignore[arg-type]
                session=session,
                **kwargs,
            )

        return await self._client._retryable_read(
            inner, read_preference, session, command_name, None, False, is_run_command=True