Method _cmd

pymongo/asynchronous/database.py:1074–1085

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

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

        async def _cmd(
            session: Optional[AsyncClientSession],
            _server: Server,
            conn: AsyncConnection,
            read_preference: _ServerMode,
        ) -> dict[str, Any]:
            return await self._command(
                conn,
                command,
                read_preference=read_preference,
                session=session,
            )

        return await self._client._retryable_read(_cmd, read_preference, session, operation)