Bug fix for options == None

Author: aclark4life

django_mongodb_backend/schema.py

@@ -430,29 +430,30 @@ def _create_collection(self, model):
         with `_get_encrypted_fields_map`.
         """
         db = self.get_database()
-        client = self.connection.connection
-        options = client._options.auto_encryption_opts
         db_table = model._meta.db_table
         if getattr(model, "encrypted", False):
-            schema_map = options._schema_map
-            if schema_map:
-                db.create_collection(db_table, encryptedFields=schema_map[db_table])
-            else:
-                key_vault_namespace = options._key_vault_namespace
-                kms_providers = options._kms_providers
-                ce = ClientEncryption(
-                    kms_providers, key_vault_namespace, client, client.codec_options
-                )
-                encrypted_fields_map = self._get_encrypted_fields_map(model)
-                provider = router.kms_provider(model)
-                credentials = self.connection.settings_dict.get("KMS_CREDENTIALS").get(provider)
-                ce.create_encrypted_collection(
-                    db,
-                    db_table,
-                    encrypted_fields_map,
-                    provider,
-                    credentials,
-                )
+            client = self.connection.connection
+            options = getattr(client._options, "auto_encryption_opts", None)
+            if options is not None:
+                schema_map = getattr(options, "_schema_map", None)
+                if schema_map:
+                    db.create_collection(db_table, encryptedFields=schema_map[db_table])
+                else:
+                    key_vault_namespace = options._key_vault_namespace
+                    kms_providers = options._kms_providers
+                    ce = ClientEncryption(
+                        kms_providers, key_vault_namespace, client, client.codec_options
+                    )
+                    encrypted_fields_map = self._get_encrypted_fields_map(model)
+                    provider = router.kms_provider(model)
+                    credentials = self.connection.settings_dict.get("KMS_CREDENTIALS").get(provider)
+                    ce.create_encrypted_collection(
+                        db,
+                        db_table,
+                        encrypted_fields_map,
+                        provider,
+                        credentials,
+                    )
         else:
             db.create_collection(db_table)