Fix weviate auth and add int test (#266)

Author: rbiseck3

CHANGELOG.md

@@ -1,4 +1,4 @@
-## 0.3.3-dev1
+## 0.3.3-dev2
 
 ### Enhancements
 
@@ -8,6 +8,7 @@
 
 * **Make AstraDB uploader truncate `text` and `text_as_html` content to max 8000 bytes**
 * **Add missing LanceDb extra**
+* **Weaviate cloud auth detection fixed**
 
 ## 0.3.2
 

test/integration/connectors/weaviate/test_cloud.py

@@ -0,0 +1,34 @@
+import pytest
+from pydantic import ValidationError
+
+from unstructured_ingest.v2.processes.connectors.weaviate.cloud import (
+    CloudWeaviateAccessConfig,
+    CloudWeaviateConnectionConfig,
+)
+
+
+def test_weaviate_failing_connection_config():
+    with pytest.raises(ValidationError):
+        CloudWeaviateConnectionConfig(
+            access_config=CloudWeaviateAccessConfig(api_key="my key", password="password"),
+            username="username",
+            cluster_url="clusterurl",
+        )
+
+
+def test_weaviate_connection_config_happy_path():
+    CloudWeaviateConnectionConfig(
+        access_config=CloudWeaviateAccessConfig(
+            api_key="my key",
+        ),
+        cluster_url="clusterurl",
+    )
+
+
+def test_weaviate_connection_config_anonymous():
+    CloudWeaviateConnectionConfig(
+        access_config=CloudWeaviateAccessConfig(api_key="my key", password="password"),
+        username="username",
+        anonymous=True,
+        cluster_url="clusterurl",
+    )

unstructured_ingest/__version__.py

@@ -1 +1 @@
-__version__ = "0.3.3-dev1"  # pragma: no cover
+__version__ = "0.3.3-dev2"  # pragma: no cover

unstructured_ingest/v2/processes/connectors/weaviate/cloud.py

@@ -55,10 +55,11 @@ def model_post_init(self, __context: Any) -> None:
             "client_secret": access_config.client_secret is not None,
             "client_password": access_config.password is not None and self.username is not None,
         }
-        if len(auths) == 0:
+        existing_auths = [auth_method for auth_method, flag in auths.items() if flag]
+
+        if len(existing_auths) == 0:
             raise ValueError("No auth values provided and anonymous is False")
-        if len(auths) > 1:
-            existing_auths = [auth_method for auth_method, flag in auths.items() if flag]
+        if len(existing_auths) > 1:
             raise ValueError(
                 "Multiple auth values provided, only one approach can be used: {}".format(
                     ", ".join(existing_auths)