Method inner

pymongo/synchronous/collection.py:651–668

(
            session: Optional[ClientSession], conn: Connection, _retryable_write: bool
        )

            cmd.update(options)

        def inner(
            session: Optional[ClientSession], conn: Connection, _retryable_write: bool
        ) -> None:
            if qev2_required and conn.max_wire_version < 21:
                raise ConfigurationError(
                    "Driver support of Queryable Encryption is incompatible with server. "
                    "Upgrade server to use Queryable Encryption. "
                    f"Got maxWireVersion {conn.max_wire_version} but need maxWireVersion >= 21 (MongoDB >=7.0)"
                )

            self._command(
                conn,
                cmd,
                read_preference=ReadPreference.PRIMARY,
                write_concern=self._write_concern_for(session),
                collation=collation,
                session=session,
            )

        self.database.client._retryable_write(False, inner, session, _Op.CREATE)