PYTHON-2186 create_indexes raises an error with commitQuorum on <4.4

Author: ShaneHarvey

pymongo/collection.py

@@ -1900,6 +1900,7 @@ def create_indexes(self, indexes, session=None, **kwargs):
         names = []
         with self._socket_for_writes(session) as sock_info:
             supports_collations = sock_info.max_wire_version >= 5
+            supports_quorum = sock_info.max_wire_version >= 9
             def gen_indexes():
                 for index in indexes:
                     if not isinstance(index, IndexModel):
@@ -1916,6 +1917,11 @@ def gen_indexes():
             cmd = SON([('createIndexes', self.name),
                        ('indexes', list(gen_indexes()))])
             cmd.update(kwargs)
+            if 'commitQuorum' in kwargs and not supports_quorum:
+                raise ConfigurationError(
+                            "Must be connected to MongoDB 4.4+ to use the "
+                            "commitQuorum option for createIndexes")
+
             self._command(
                 sock_info, cmd, read_preference=ReadPreference.PRIMARY,
                 codec_options=_UNICODE_REPLACE_CODEC_OPTIONS,

test/test_collection.py

@@ -234,6 +234,20 @@ def test_create_indexes(self):
         with self.write_concern_collection() as coll:
             coll.create_indexes([IndexModel('hello')])
 
+    @client_context.require_version_max(4, 3, -1)
+    def test_create_indexes_commitQuorum_requires_44(self):
+        db = self.db
+        with self.assertRaisesRegex(
+                ConfigurationError,
+                'Must be connected to MongoDB 4\.4\+ to use the commitQuorum '
+                'option for createIndexes'):
+            db.coll.create_indexes([IndexModel('a')], commitQuorum="majority")
+
+    @client_context.require_no_standalone
+    @client_context.require_version_min(4, 4, -1)
+    def test_create_indexes_commitQuorum(self):
+        self.db.coll.create_indexes([IndexModel('a')], commitQuorum="majority")
+
     def test_create_index(self):
         db = self.db