bugfix/add missing azure openai embedder implementation (#370)

* Add missing azure openai embedder implementation

* include connector assets in package data

Author: rbiseck3

CHANGELOG.md

@@ -1,7 +1,8 @@
-## 0.4.7-dev0
+## 0.4.7
 
 ### Fixes
 
+* **Add missing async azure openai embedder implementation**
 * **Update Sharepont to support new Microsoft credential sequence**
 
 ## 0.4.6

MANIFEST.in

@@ -0,0 +1,2 @@
+# Connector specific assets
+include unstructured_ingest/v2/processes/connectors/assets/*

setup.py

@@ -204,4 +204,5 @@ def load_requirements(file: Union[str, Path]) -> List[str]:
     extras_require=extras_require,
     package_dir={"unstructured_ingest": "unstructured_ingest"},
     package_data={"unstructured_ingest": ["py.typed"]},
+    include_package_data=True,
 )

test_file.pdf

@@ -1 +1 @@
-__version__ = "0.4.7-dev0"  # pragma: no cover
+__version__ = "0.4.7"  # pragma: no cover

unstructured_ingest/__version__.py

@@ -3,11 +3,15 @@
 
 from pydantic import Field
 
-from unstructured_ingest.embed.openai import OpenAIEmbeddingConfig, OpenAIEmbeddingEncoder
+from unstructured_ingest.embed.openai import (
+    AsyncOpenAIEmbeddingEncoder,
+    OpenAIEmbeddingConfig,
+    OpenAIEmbeddingEncoder,
+)
 from unstructured_ingest.utils.dep_check import requires_dependencies
 
 if TYPE_CHECKING:
-    from openai import AzureOpenAI
+    from openai import AsyncAzureOpenAI, AzureOpenAI
 
 
 class AzureOpenAIEmbeddingConfig(OpenAIEmbeddingConfig):
@@ -25,7 +29,22 @@ def get_client(self) -> "AzureOpenAI":
             azure_endpoint=self.azure_endpoint,
         )
 
+    @requires_dependencies(["openai"], extras="openai")
+    def get_async_client(self) -> "AsyncAzureOpenAI":
+        from openai import AsyncAzureOpenAI
+
+        return AsyncAzureOpenAI(
+            api_key=self.api_key.get_secret_value(),
+            api_version=self.api_version,
+            azure_endpoint=self.azure_endpoint,
+        )
+
 
 @dataclass
 class AzureOpenAIEmbeddingEncoder(OpenAIEmbeddingEncoder):
     config: AzureOpenAIEmbeddingConfig
+
+
+@dataclass
+class AsyncAzureOpenAIEmbeddingEncoder(AsyncOpenAIEmbeddingEncoder):
+    config: AzureOpenAIEmbeddingConfig