diff --git a/.speakeasy/gen.lock b/.speakeasy/gen.lock index 701bc124..c2e89a9f 100755 --- a/.speakeasy/gen.lock +++ b/.speakeasy/gen.lock @@ -1,12 +1,12 @@ lockVersion: 2.0.0 id: 8b5fa338-9106-4734-abf0-e30d67044a90 management: - docChecksum: 82d55672df290a1b6b3641bf1c0385a0 + docChecksum: f5acf2abe837ecf85e4549af6c864e95 docVersion: 1.1.4 - speakeasyVersion: 1.526.0 - generationVersion: 2.563.0 - releaseVersion: 0.32.0 - configChecksum: aaffd2f8109b46337a8b440562051f7a + speakeasyVersion: 1.528.1 + generationVersion: 2.565.1 + releaseVersion: 0.32.1 + configChecksum: 0ee63f2ec67ee05b651d54a09c7c935e repoURL: https://github.com/Unstructured-IO/unstructured-python-client.git repoSubDirectory: . installationURL: https://github.com/Unstructured-IO/unstructured-python-client.git @@ -16,7 +16,7 @@ features: acceptHeaders: 3.0.0 additionalDependencies: 1.0.0 constsAndDefaults: 1.0.5 - core: 5.12.4 + core: 5.12.5 defaultEnabledRetries: 0.2.0 enumUnions: 0.1.0 envVarSecurityUsage: 0.3.2 @@ -29,7 +29,7 @@ features: multipartFileContentType: 1.0.0 nameOverrides: 3.0.1 nullables: 1.0.1 - openEnums: 1.0.0 + openEnums: 1.0.1 responseFormat: 1.0.1 retries: 3.0.2 sdkHooks: 1.0.1 @@ -90,6 +90,8 @@ generatedFiles: - docs/models/shared/astradbconnectorconfiginput.md - docs/models/shared/azureaisearchconnectorconfig.md - docs/models/shared/azureaisearchconnectorconfiginput.md + - docs/models/shared/azuredestinationconnectorconfig.md + - docs/models/shared/azuredestinationconnectorconfiginput.md - docs/models/shared/azuresourceconnectorconfig.md - docs/models/shared/azuresourceconnectorconfiginput.md - docs/models/shared/bodyrunworkflow.md @@ -253,6 +255,8 @@ generatedFiles: - src/unstructured_client/models/shared/astradbconnectorconfiginput.py - src/unstructured_client/models/shared/azureaisearchconnectorconfig.py - src/unstructured_client/models/shared/azureaisearchconnectorconfiginput.py + - src/unstructured_client/models/shared/azuredestinationconnectorconfig.py + - src/unstructured_client/models/shared/azuredestinationconnectorconfiginput.py - src/unstructured_client/models/shared/azuresourceconnectorconfig.py - src/unstructured_client/models/shared/azuresourceconnectorconfiginput.py - src/unstructured_client/models/shared/body_run_workflow.py diff --git a/.speakeasy/workflow.lock b/.speakeasy/workflow.lock index e562784c..28227040 100644 --- a/.speakeasy/workflow.lock +++ b/.speakeasy/workflow.lock @@ -1,21 +1,21 @@ -speakeasyVersion: 1.526.0 +speakeasyVersion: 1.528.1 sources: my-source: sourceNamespace: my-source - sourceRevisionDigest: sha256:b7ee9aa59b47e0b739012e611720330b6870798eb256e44c15d0c55832dc1207 - sourceBlobDigest: sha256:19ebaffb7c44a42ce3fbdf03cf5fe0f4a68956d59d6f3239d8b6a5b16e1c07e5 + sourceRevisionDigest: sha256:3ef2e923ab2125c8a01080f5bdd566de7d8321ce4dd55741d5f73cefcd607c92 + sourceBlobDigest: sha256:456351471925fa73f1e21cd9cf562192b638407448b3eebb995af1412def0801 tags: - latest - - speakeasy-sdk-regen-1743188464 + - speakeasy-sdk-regen-1743639002 - 1.1.4 targets: unstructured-python: source: my-source sourceNamespace: my-source - sourceRevisionDigest: sha256:b7ee9aa59b47e0b739012e611720330b6870798eb256e44c15d0c55832dc1207 - sourceBlobDigest: sha256:19ebaffb7c44a42ce3fbdf03cf5fe0f4a68956d59d6f3239d8b6a5b16e1c07e5 + sourceRevisionDigest: sha256:3ef2e923ab2125c8a01080f5bdd566de7d8321ce4dd55741d5f73cefcd607c92 + sourceBlobDigest: sha256:456351471925fa73f1e21cd9cf562192b638407448b3eebb995af1412def0801 codeSamplesNamespace: my-source-code-samples - codeSamplesRevisionDigest: sha256:0696c1f0b1f0274a950cd103dd855cc721ada1716468d57138e7370f7f7e9ea4 + codeSamplesRevisionDigest: sha256:fd9f7b1049617cfcfdd5f458b9291bc702426e0e8c17d4f39d6ce488857a06d4 workflow: workflowVersion: 1.0.0 speakeasyVersion: latest diff --git a/RELEASES.md b/RELEASES.md index 8bec9b26..fd60250a 100644 --- a/RELEASES.md +++ b/RELEASES.md @@ -915,4 +915,14 @@ Based on: ### Generated - [python v0.32.0] . ### Releases -- [PyPI v0.32.0] https://pypi.org/project/unstructured-client/0.32.0 - . \ No newline at end of file +- [PyPI v0.32.0] https://pypi.org/project/unstructured-client/0.32.0 - . + +## 2025-04-03 00:09:46 +### Changes +Based on: +- OpenAPI Doc +- Speakeasy CLI 1.528.1 (2.565.1) https://github.com/speakeasy-api/speakeasy +### Generated +- [python v0.32.1] . +### Releases +- [PyPI v0.32.1] https://pypi.org/project/unstructured-client/0.32.1 - . \ No newline at end of file diff --git a/codeSamples.yaml b/codeSamples.yaml index 2503dd7f..cb83c5a6 100644 --- a/codeSamples.yaml +++ b/codeSamples.yaml @@ -14,7 +14,7 @@ actions: "x-codeSamples": - "lang": "python" "label": "create_destination" - "source": "from unstructured_client import UnstructuredClient\nfrom unstructured_client.models import shared\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.destinations.create_destination(request={\n \"create_destination_connector\": {\n \"name\": \"\",\n \"type\": shared.DestinationConnectorType.AZURE_AI_SEARCH,\n \"config\": {\n \"collection_name\": \"\",\n \"batch_size\": 20,\n \"api_endpoint\": \"\",\n \"token\": \"\",\n \"flatten_metadata\": False,\n },\n },\n })\n\n assert res.destination_connector_information is not None\n\n # Handle response\n print(res.destination_connector_information)" + "source": "from unstructured_client import UnstructuredClient\nfrom unstructured_client.models import shared\n\n\nwith UnstructuredClient() as uc_client:\n\n res = uc_client.destinations.create_destination(request={\n \"create_destination_connector\": {\n \"name\": \"\",\n \"type\": shared.DestinationConnectorType.ASTRADB,\n \"config\": {\n \"remote_url\": \"https://fortunate-appliance.info\",\n \"anonymous\": False,\n },\n },\n })\n\n assert res.destination_connector_information is not None\n\n # Handle response\n print(res.destination_connector_information)" - target: $["paths"]["/api/v1/destinations/{destination_id}"]["delete"] update: "x-codeSamples": diff --git a/docs/models/shared/azuredestinationconnectorconfig.md b/docs/models/shared/azuredestinationconnectorconfig.md new file mode 100644 index 00000000..ac2c4973 --- /dev/null +++ b/docs/models/shared/azuredestinationconnectorconfig.md @@ -0,0 +1,12 @@ +# AzureDestinationConnectorConfig + + +## Fields + +| Field | Type | Required | Description | +| ----------------------- | ----------------------- | ----------------------- | ----------------------- | +| `remote_url` | *str* | :heavy_check_mark: | N/A | +| `account_key` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | +| `account_name` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | +| `connection_string` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | +| `sas_token` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | \ No newline at end of file diff --git a/docs/models/shared/azuredestinationconnectorconfiginput.md b/docs/models/shared/azuredestinationconnectorconfiginput.md new file mode 100644 index 00000000..a396ffc5 --- /dev/null +++ b/docs/models/shared/azuredestinationconnectorconfiginput.md @@ -0,0 +1,12 @@ +# AzureDestinationConnectorConfigInput + + +## Fields + +| Field | Type | Required | Description | +| ----------------------- | ----------------------- | ----------------------- | ----------------------- | +| `remote_url` | *str* | :heavy_check_mark: | N/A | +| `account_key` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | +| `account_name` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | +| `connection_string` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | +| `sas_token` | *OptionalNullable[str]* | :heavy_minus_sign: | N/A | \ No newline at end of file diff --git a/docs/models/shared/config.md b/docs/models/shared/config.md index 457e0fd7..cd0363d3 100644 --- a/docs/models/shared/config.md +++ b/docs/models/shared/config.md @@ -3,6 +3,12 @@ ## Supported Types +### `shared.AzureDestinationConnectorConfigInput` + +```python +value: shared.AzureDestinationConnectorConfigInput = /* values here */ +``` + ### `shared.AstraDBConnectorConfigInput` ```python diff --git a/docs/models/shared/destinationconnectorinformationconfig.md b/docs/models/shared/destinationconnectorinformationconfig.md index 3a711755..f18f6d71 100644 --- a/docs/models/shared/destinationconnectorinformationconfig.md +++ b/docs/models/shared/destinationconnectorinformationconfig.md @@ -3,6 +3,12 @@ ## Supported Types +### `shared.AzureDestinationConnectorConfig` + +```python +value: shared.AzureDestinationConnectorConfig = /* values here */ +``` + ### `shared.AstraDBConnectorConfig` ```python diff --git a/docs/models/shared/destinationconnectortype.md b/docs/models/shared/destinationconnectortype.md index 57c24960..7137af3e 100644 --- a/docs/models/shared/destinationconnectortype.md +++ b/docs/models/shared/destinationconnectortype.md @@ -5,6 +5,7 @@ | Name | Value | | -------------------------------- | -------------------------------- | +| `AZURE` | azure | | `ASTRADB` | astradb | | `AZURE_AI_SEARCH` | azure_ai_search | | `COUCHBASE` | couchbase | diff --git a/docs/models/shared/updatedestinationconnectorconfig.md b/docs/models/shared/updatedestinationconnectorconfig.md index 78d91893..a7f36d4c 100644 --- a/docs/models/shared/updatedestinationconnectorconfig.md +++ b/docs/models/shared/updatedestinationconnectorconfig.md @@ -3,6 +3,12 @@ ## Supported Types +### `shared.AzureDestinationConnectorConfigInput` + +```python +value: shared.AzureDestinationConnectorConfigInput = /* values here */ +``` + ### `shared.AstraDBConnectorConfigInput` ```python diff --git a/gen.yaml b/gen.yaml index 305b4952..e34c5750 100644 --- a/gen.yaml +++ b/gen.yaml @@ -12,7 +12,7 @@ generation: oAuth2ClientCredentialsEnabled: false oAuth2PasswordEnabled: false python: - version: 0.32.0 + version: 0.32.1 additionalDependencies: dev: deepdiff: '>=6.0' diff --git a/pyproject.toml b/pyproject.toml index fe19dc4f..36112444 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "unstructured-client" -version = "0.32.0" +version = "0.32.1" description = "Python Client SDK for Unstructured API" authors = [{ name = "Unstructured" },] readme = "README-PYPI.md" diff --git a/src/unstructured_client/_version.py b/src/unstructured_client/_version.py index a7e13028..d2a68679 100644 --- a/src/unstructured_client/_version.py +++ b/src/unstructured_client/_version.py @@ -3,10 +3,10 @@ import importlib.metadata __title__: str = "unstructured-client" -__version__: str = "0.32.0" +__version__: str = "0.32.1" __openapi_doc_version__: str = "1.1.4" -__gen_version__: str = "2.563.0" -__user_agent__: str = "speakeasy-sdk/python 0.32.0 2.563.0 1.1.4 unstructured-client" +__gen_version__: str = "2.565.1" +__user_agent__: str = "speakeasy-sdk/python 0.32.1 2.565.1 1.1.4 unstructured-client" try: if __package__ is not None: diff --git a/src/unstructured_client/models/operations/cancel_job.py b/src/unstructured_client/models/operations/cancel_job.py index 4b3afc89..9ebe33b4 100644 --- a/src/unstructured_client/models/operations/cancel_job.py +++ b/src/unstructured_client/models/operations/cancel_job.py @@ -49,7 +49,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/create_destination.py b/src/unstructured_client/models/operations/create_destination.py index 605d828b..7f2b8589 100644 --- a/src/unstructured_client/models/operations/create_destination.py +++ b/src/unstructured_client/models/operations/create_destination.py @@ -56,7 +56,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/create_source.py b/src/unstructured_client/models/operations/create_source.py index ececa828..bceca31f 100644 --- a/src/unstructured_client/models/operations/create_source.py +++ b/src/unstructured_client/models/operations/create_source.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/create_workflow.py b/src/unstructured_client/models/operations/create_workflow.py index a645e851..d3fc1f49 100644 --- a/src/unstructured_client/models/operations/create_workflow.py +++ b/src/unstructured_client/models/operations/create_workflow.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/delete_destination.py b/src/unstructured_client/models/operations/delete_destination.py index b26d57d1..0dca87ea 100644 --- a/src/unstructured_client/models/operations/delete_destination.py +++ b/src/unstructured_client/models/operations/delete_destination.py @@ -49,7 +49,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/delete_source.py b/src/unstructured_client/models/operations/delete_source.py index 80ad6ac2..7a66281d 100644 --- a/src/unstructured_client/models/operations/delete_source.py +++ b/src/unstructured_client/models/operations/delete_source.py @@ -49,7 +49,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/delete_workflow.py b/src/unstructured_client/models/operations/delete_workflow.py index 693e313e..1894134f 100644 --- a/src/unstructured_client/models/operations/delete_workflow.py +++ b/src/unstructured_client/models/operations/delete_workflow.py @@ -49,7 +49,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/download_job_output.py b/src/unstructured_client/models/operations/download_job_output.py index 2e31035f..4130a2b0 100644 --- a/src/unstructured_client/models/operations/download_job_output.py +++ b/src/unstructured_client/models/operations/download_job_output.py @@ -69,7 +69,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/get_destination.py b/src/unstructured_client/models/operations/get_destination.py index cff521f2..fb7c1f65 100644 --- a/src/unstructured_client/models/operations/get_destination.py +++ b/src/unstructured_client/models/operations/get_destination.py @@ -52,7 +52,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/get_job.py b/src/unstructured_client/models/operations/get_job.py index 03dd278d..96c4dcb1 100644 --- a/src/unstructured_client/models/operations/get_job.py +++ b/src/unstructured_client/models/operations/get_job.py @@ -50,7 +50,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/get_source.py b/src/unstructured_client/models/operations/get_source.py index aefb9316..746758fa 100644 --- a/src/unstructured_client/models/operations/get_source.py +++ b/src/unstructured_client/models/operations/get_source.py @@ -52,7 +52,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/get_workflow.py b/src/unstructured_client/models/operations/get_workflow.py index 6563251f..6df4abb8 100644 --- a/src/unstructured_client/models/operations/get_workflow.py +++ b/src/unstructured_client/models/operations/get_workflow.py @@ -52,7 +52,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/list_destinations.py b/src/unstructured_client/models/operations/list_destinations.py index 693c4d0b..7244e1c7 100644 --- a/src/unstructured_client/models/operations/list_destinations.py +++ b/src/unstructured_client/models/operations/list_destinations.py @@ -56,7 +56,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/list_jobs.py b/src/unstructured_client/models/operations/list_jobs.py index ababd3f0..042d4f98 100644 --- a/src/unstructured_client/models/operations/list_jobs.py +++ b/src/unstructured_client/models/operations/list_jobs.py @@ -57,7 +57,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/list_sources.py b/src/unstructured_client/models/operations/list_sources.py index 4c53a5dd..d3173496 100644 --- a/src/unstructured_client/models/operations/list_sources.py +++ b/src/unstructured_client/models/operations/list_sources.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/list_workflows.py b/src/unstructured_client/models/operations/list_workflows.py index 051932df..8c8975f3 100644 --- a/src/unstructured_client/models/operations/list_workflows.py +++ b/src/unstructured_client/models/operations/list_workflows.py @@ -76,7 +76,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/partition.py b/src/unstructured_client/models/operations/partition.py index b1d77862..7474be82 100644 --- a/src/unstructured_client/models/operations/partition.py +++ b/src/unstructured_client/models/operations/partition.py @@ -61,7 +61,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/run_workflow.py b/src/unstructured_client/models/operations/run_workflow.py index c615d0d1..ad6969ff 100644 --- a/src/unstructured_client/models/operations/run_workflow.py +++ b/src/unstructured_client/models/operations/run_workflow.py @@ -64,7 +64,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/update_destination.py b/src/unstructured_client/models/operations/update_destination.py index 7b2c0f99..08acbfb0 100644 --- a/src/unstructured_client/models/operations/update_destination.py +++ b/src/unstructured_client/models/operations/update_destination.py @@ -66,7 +66,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/update_source.py b/src/unstructured_client/models/operations/update_source.py index bdd9944d..1ce7d5e2 100644 --- a/src/unstructured_client/models/operations/update_source.py +++ b/src/unstructured_client/models/operations/update_source.py @@ -64,7 +64,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/operations/update_workflow.py b/src/unstructured_client/models/operations/update_workflow.py index ba614fb9..88003b5b 100644 --- a/src/unstructured_client/models/operations/update_workflow.py +++ b/src/unstructured_client/models/operations/update_workflow.py @@ -64,7 +64,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/__init__.py b/src/unstructured_client/models/shared/__init__.py index 32fc4ca0..a69961fa 100644 --- a/src/unstructured_client/models/shared/__init__.py +++ b/src/unstructured_client/models/shared/__init__.py @@ -16,6 +16,14 @@ AzureAISearchConnectorConfigInput, AzureAISearchConnectorConfigInputTypedDict, ) +from .azuredestinationconnectorconfig import ( + AzureDestinationConnectorConfig, + AzureDestinationConnectorConfigTypedDict, +) +from .azuredestinationconnectorconfiginput import ( + AzureDestinationConnectorConfigInput, + AzureDestinationConnectorConfigInputTypedDict, +) from .azuresourceconnectorconfig import ( AzureSourceConnectorConfig, AzureSourceConnectorConfigTypedDict, @@ -384,6 +392,10 @@ "AzureAISearchConnectorConfigInput", "AzureAISearchConnectorConfigInputTypedDict", "AzureAISearchConnectorConfigTypedDict", + "AzureDestinationConnectorConfig", + "AzureDestinationConnectorConfigInput", + "AzureDestinationConnectorConfigInputTypedDict", + "AzureDestinationConnectorConfigTypedDict", "AzureSourceConnectorConfig", "AzureSourceConnectorConfigInput", "AzureSourceConnectorConfigInputTypedDict", diff --git a/src/unstructured_client/models/shared/astradbconnectorconfig.py b/src/unstructured_client/models/shared/astradbconnectorconfig.py index d1a08fb4..64c3f17c 100644 --- a/src/unstructured_client/models/shared/astradbconnectorconfig.py +++ b/src/unstructured_client/models/shared/astradbconnectorconfig.py @@ -41,7 +41,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/astradbconnectorconfiginput.py b/src/unstructured_client/models/shared/astradbconnectorconfiginput.py index 39eee29d..a22dfe29 100644 --- a/src/unstructured_client/models/shared/astradbconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/astradbconnectorconfiginput.py @@ -45,7 +45,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/azuredestinationconnectorconfig.py b/src/unstructured_client/models/shared/azuredestinationconnectorconfig.py new file mode 100644 index 00000000..31075deb --- /dev/null +++ b/src/unstructured_client/models/shared/azuredestinationconnectorconfig.py @@ -0,0 +1,72 @@ +"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.""" + +from __future__ import annotations +from pydantic import model_serializer +from typing_extensions import NotRequired, TypedDict +from unstructured_client.types import ( + BaseModel, + Nullable, + OptionalNullable, + UNSET, + UNSET_SENTINEL, +) + + +class AzureDestinationConnectorConfigTypedDict(TypedDict): + remote_url: str + account_key: NotRequired[Nullable[str]] + account_name: NotRequired[Nullable[str]] + connection_string: NotRequired[Nullable[str]] + sas_token: NotRequired[Nullable[str]] + + +class AzureDestinationConnectorConfig(BaseModel): + remote_url: str + + account_key: OptionalNullable[str] = UNSET + + account_name: OptionalNullable[str] = UNSET + + connection_string: OptionalNullable[str] = UNSET + + sas_token: OptionalNullable[str] = UNSET + + @model_serializer(mode="wrap") + def serialize_model(self, handler): + optional_fields = [ + "account_key", + "account_name", + "connection_string", + "sas_token", + ] + nullable_fields = [ + "account_key", + "account_name", + "connection_string", + "sas_token", + ] + null_default_fields = [] + + serialized = handler(self) + + m = {} + + for n, f in type(self).model_fields.items(): + k = f.alias or n + val = serialized.get(k) + serialized.pop(k, None) + + optional_nullable = k in optional_fields and k in nullable_fields + is_set = ( + self.__pydantic_fields_set__.intersection({n}) + or k in null_default_fields + ) # pylint: disable=no-member + + if val is not None and val != UNSET_SENTINEL: + m[k] = val + elif val != UNSET_SENTINEL and ( + not k in optional_fields or (optional_nullable and is_set) + ): + m[k] = val + + return m diff --git a/src/unstructured_client/models/shared/azuredestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/azuredestinationconnectorconfiginput.py new file mode 100644 index 00000000..caebb2c0 --- /dev/null +++ b/src/unstructured_client/models/shared/azuredestinationconnectorconfiginput.py @@ -0,0 +1,72 @@ +"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.""" + +from __future__ import annotations +from pydantic import model_serializer +from typing_extensions import NotRequired, TypedDict +from unstructured_client.types import ( + BaseModel, + Nullable, + OptionalNullable, + UNSET, + UNSET_SENTINEL, +) + + +class AzureDestinationConnectorConfigInputTypedDict(TypedDict): + remote_url: str + account_key: NotRequired[Nullable[str]] + account_name: NotRequired[Nullable[str]] + connection_string: NotRequired[Nullable[str]] + sas_token: NotRequired[Nullable[str]] + + +class AzureDestinationConnectorConfigInput(BaseModel): + remote_url: str + + account_key: OptionalNullable[str] = UNSET + + account_name: OptionalNullable[str] = UNSET + + connection_string: OptionalNullable[str] = UNSET + + sas_token: OptionalNullable[str] = UNSET + + @model_serializer(mode="wrap") + def serialize_model(self, handler): + optional_fields = [ + "account_key", + "account_name", + "connection_string", + "sas_token", + ] + nullable_fields = [ + "account_key", + "account_name", + "connection_string", + "sas_token", + ] + null_default_fields = [] + + serialized = handler(self) + + m = {} + + for n, f in type(self).model_fields.items(): + k = f.alias or n + val = serialized.get(k) + serialized.pop(k, None) + + optional_nullable = k in optional_fields and k in nullable_fields + is_set = ( + self.__pydantic_fields_set__.intersection({n}) + or k in null_default_fields + ) # pylint: disable=no-member + + if val is not None and val != UNSET_SENTINEL: + m[k] = val + elif val != UNSET_SENTINEL and ( + not k in optional_fields or (optional_nullable and is_set) + ): + m[k] = val + + return m diff --git a/src/unstructured_client/models/shared/azuresourceconnectorconfig.py b/src/unstructured_client/models/shared/azuresourceconnectorconfig.py index 811b1acc..adbee500 100644 --- a/src/unstructured_client/models/shared/azuresourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/azuresourceconnectorconfig.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/azuresourceconnectorconfiginput.py b/src/unstructured_client/models/shared/azuresourceconnectorconfiginput.py index 30f31bf7..70fa5e65 100644 --- a/src/unstructured_client/models/shared/azuresourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/azuresourceconnectorconfiginput.py @@ -56,7 +56,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/body_run_workflow.py b/src/unstructured_client/models/shared/body_run_workflow.py index 9afa031a..66f7f51b 100644 --- a/src/unstructured_client/models/shared/body_run_workflow.py +++ b/src/unstructured_client/models/shared/body_run_workflow.py @@ -59,7 +59,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/confluencesourceconnectorconfig.py b/src/unstructured_client/models/shared/confluencesourceconnectorconfig.py index 02cf4597..cfd8c41e 100644 --- a/src/unstructured_client/models/shared/confluencesourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/confluencesourceconnectorconfig.py @@ -57,7 +57,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/confluencesourceconnectorconfiginput.py b/src/unstructured_client/models/shared/confluencesourceconnectorconfiginput.py index 2afec1d1..030b4882 100644 --- a/src/unstructured_client/models/shared/confluencesourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/confluencesourceconnectorconfiginput.py @@ -66,7 +66,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/couchbasedestinationconnectorconfig.py b/src/unstructured_client/models/shared/couchbasedestinationconnectorconfig.py index bfd2f7cd..32150527 100644 --- a/src/unstructured_client/models/shared/couchbasedestinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/couchbasedestinationconnectorconfig.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/couchbasedestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/couchbasedestinationconnectorconfiginput.py index 2d4d9adf..27999cb1 100644 --- a/src/unstructured_client/models/shared/couchbasedestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/couchbasedestinationconnectorconfiginput.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/couchbasesourceconnectorconfig.py b/src/unstructured_client/models/shared/couchbasesourceconnectorconfig.py index e202f8b5..5a6d559a 100644 --- a/src/unstructured_client/models/shared/couchbasesourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/couchbasesourceconnectorconfig.py @@ -50,7 +50,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/couchbasesourceconnectorconfiginput.py b/src/unstructured_client/models/shared/couchbasesourceconnectorconfiginput.py index f36e379c..58d9451b 100644 --- a/src/unstructured_client/models/shared/couchbasesourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/couchbasesourceconnectorconfiginput.py @@ -50,7 +50,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/createdestinationconnector.py b/src/unstructured_client/models/shared/createdestinationconnector.py index a6699c29..2a3cbbe2 100644 --- a/src/unstructured_client/models/shared/createdestinationconnector.py +++ b/src/unstructured_client/models/shared/createdestinationconnector.py @@ -9,6 +9,10 @@ AzureAISearchConnectorConfigInput, AzureAISearchConnectorConfigInputTypedDict, ) +from .azuredestinationconnectorconfiginput import ( + AzureDestinationConnectorConfigInput, + AzureDestinationConnectorConfigInputTypedDict, +) from .couchbasedestinationconnectorconfiginput import ( CouchbaseDestinationConnectorConfigInput, CouchbaseDestinationConnectorConfigInputTypedDict, @@ -92,20 +96,21 @@ Union[ GCSDestinationConnectorConfigInputTypedDict, ElasticsearchConnectorConfigInputTypedDict, + MongoDBConnectorConfigInputTypedDict, AzureAISearchConnectorConfigInputTypedDict, WeaviateDestinationConnectorConfigInputTypedDict, - MongoDBConnectorConfigInputTypedDict, DeltaTableConnectorConfigInputTypedDict, QdrantCloudDestinationConnectorConfigInputTypedDict, PineconeDestinationConnectorConfigInputTypedDict, + AzureDestinationConnectorConfigInputTypedDict, Neo4jDestinationConnectorConfigInputTypedDict, OneDriveDestinationConnectorConfigInputTypedDict, S3DestinationConnectorConfigInputTypedDict, AstraDBConnectorConfigInputTypedDict, - MilvusDestinationConnectorConfigInputTypedDict, - DatabricksVolumesConnectorConfigInputTypedDict, PostgresDestinationConnectorConfigInputTypedDict, + MilvusDestinationConnectorConfigInputTypedDict, KafkaCloudDestinationConnectorConfigInputTypedDict, + DatabricksVolumesConnectorConfigInputTypedDict, CouchbaseDestinationConnectorConfigInputTypedDict, RedisDestinationConnectorConfigInputTypedDict, DatabricksVDTDestinationConnectorConfigInputTypedDict, @@ -119,20 +124,21 @@ Union[ GCSDestinationConnectorConfigInput, ElasticsearchConnectorConfigInput, + MongoDBConnectorConfigInput, AzureAISearchConnectorConfigInput, WeaviateDestinationConnectorConfigInput, - MongoDBConnectorConfigInput, DeltaTableConnectorConfigInput, QdrantCloudDestinationConnectorConfigInput, PineconeDestinationConnectorConfigInput, + AzureDestinationConnectorConfigInput, Neo4jDestinationConnectorConfigInput, OneDriveDestinationConnectorConfigInput, S3DestinationConnectorConfigInput, AstraDBConnectorConfigInput, - MilvusDestinationConnectorConfigInput, - DatabricksVolumesConnectorConfigInput, PostgresDestinationConnectorConfigInput, + MilvusDestinationConnectorConfigInput, KafkaCloudDestinationConnectorConfigInput, + DatabricksVolumesConnectorConfigInput, CouchbaseDestinationConnectorConfigInput, RedisDestinationConnectorConfigInput, DatabricksVDTDestinationConnectorConfigInput, diff --git a/src/unstructured_client/models/shared/createworkflow.py b/src/unstructured_client/models/shared/createworkflow.py index 332cfd93..f2892c60 100644 --- a/src/unstructured_client/models/shared/createworkflow.py +++ b/src/unstructured_client/models/shared/createworkflow.py @@ -62,7 +62,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfig.py b/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfig.py index aef17601..c87b70da 100644 --- a/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfig.py @@ -67,7 +67,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfiginput.py index e12eb64d..88c34741 100644 --- a/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/databricksvdtdestinationconnectorconfiginput.py @@ -67,7 +67,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/destinationconnectorinformation.py b/src/unstructured_client/models/shared/destinationconnectorinformation.py index 781e1525..5dbc0e58 100644 --- a/src/unstructured_client/models/shared/destinationconnectorinformation.py +++ b/src/unstructured_client/models/shared/destinationconnectorinformation.py @@ -9,6 +9,10 @@ AzureAISearchConnectorConfig, AzureAISearchConnectorConfigTypedDict, ) +from .azuredestinationconnectorconfig import ( + AzureDestinationConnectorConfig, + AzureDestinationConnectorConfigTypedDict, +) from .couchbasedestinationconnectorconfig import ( CouchbaseDestinationConnectorConfig, CouchbaseDestinationConnectorConfigTypedDict, @@ -100,20 +104,21 @@ Union[ GCSDestinationConnectorConfigTypedDict, ElasticsearchConnectorConfigTypedDict, + MongoDBConnectorConfigTypedDict, AzureAISearchConnectorConfigTypedDict, WeaviateDestinationConnectorConfigTypedDict, - MongoDBConnectorConfigTypedDict, DeltaTableConnectorConfigTypedDict, QdrantCloudDestinationConnectorConfigTypedDict, PineconeDestinationConnectorConfigTypedDict, + AzureDestinationConnectorConfigTypedDict, AstraDBConnectorConfigTypedDict, Neo4jDestinationConnectorConfigTypedDict, OneDriveDestinationConnectorConfigTypedDict, S3DestinationConnectorConfigTypedDict, - MilvusDestinationConnectorConfigTypedDict, - DatabricksVolumesConnectorConfigTypedDict, PostgresDestinationConnectorConfigTypedDict, + MilvusDestinationConnectorConfigTypedDict, KafkaCloudDestinationConnectorConfigTypedDict, + DatabricksVolumesConnectorConfigTypedDict, CouchbaseDestinationConnectorConfigTypedDict, RedisDestinationConnectorConfigTypedDict, DatabricksVDTDestinationConnectorConfigTypedDict, @@ -127,20 +132,21 @@ Union[ GCSDestinationConnectorConfig, ElasticsearchConnectorConfig, + MongoDBConnectorConfig, AzureAISearchConnectorConfig, WeaviateDestinationConnectorConfig, - MongoDBConnectorConfig, DeltaTableConnectorConfig, QdrantCloudDestinationConnectorConfig, PineconeDestinationConnectorConfig, + AzureDestinationConnectorConfig, AstraDBConnectorConfig, Neo4jDestinationConnectorConfig, OneDriveDestinationConnectorConfig, S3DestinationConnectorConfig, - MilvusDestinationConnectorConfig, - DatabricksVolumesConnectorConfig, PostgresDestinationConnectorConfig, + MilvusDestinationConnectorConfig, KafkaCloudDestinationConnectorConfig, + DatabricksVolumesConnectorConfig, CouchbaseDestinationConnectorConfig, RedisDestinationConnectorConfig, DatabricksVDTDestinationConnectorConfig, @@ -181,7 +187,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/destinationconnectortype.py b/src/unstructured_client/models/shared/destinationconnectortype.py index 098a3b38..f61c4a77 100644 --- a/src/unstructured_client/models/shared/destinationconnectortype.py +++ b/src/unstructured_client/models/shared/destinationconnectortype.py @@ -5,6 +5,7 @@ class DestinationConnectorType(str, Enum): + AZURE = "azure" ASTRADB = "astradb" AZURE_AI_SEARCH = "azure_ai_search" COUCHBASE = "couchbase" diff --git a/src/unstructured_client/models/shared/googledrivesourceconnectorconfig.py b/src/unstructured_client/models/shared/googledrivesourceconnectorconfig.py index 9b888784..b8ab1385 100644 --- a/src/unstructured_client/models/shared/googledrivesourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/googledrivesourceconnectorconfig.py @@ -39,7 +39,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/googledrivesourceconnectorconfiginput.py b/src/unstructured_client/models/shared/googledrivesourceconnectorconfiginput.py index 58b8f095..3d5c27dd 100644 --- a/src/unstructured_client/models/shared/googledrivesourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/googledrivesourceconnectorconfiginput.py @@ -39,7 +39,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/jirasourceconnectorconfig.py b/src/unstructured_client/models/shared/jirasourceconnectorconfig.py index e5486770..aabcd8d2 100644 --- a/src/unstructured_client/models/shared/jirasourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/jirasourceconnectorconfig.py @@ -51,7 +51,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/jirasourceconnectorconfiginput.py b/src/unstructured_client/models/shared/jirasourceconnectorconfiginput.py index 624def94..043090b1 100644 --- a/src/unstructured_client/models/shared/jirasourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/jirasourceconnectorconfiginput.py @@ -51,7 +51,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/jobinformation.py b/src/unstructured_client/models/shared/jobinformation.py index d6717e63..6b65dd23 100644 --- a/src/unstructured_client/models/shared/jobinformation.py +++ b/src/unstructured_client/models/shared/jobinformation.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfig.py b/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfig.py index ad0e937a..45a2f927 100644 --- a/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfig.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfiginput.py index bc9b1a48..fa10cfb5 100644 --- a/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/kafkaclouddestinationconnectorconfiginput.py @@ -48,7 +48,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfig.py b/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfig.py index 829e70cb..4d975609 100644 --- a/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfig.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfiginput.py b/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfiginput.py index 3eddd5d5..599120d9 100644 --- a/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/kafkacloudsourceconnectorconfiginput.py @@ -48,7 +48,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/milvusdestinationconnectorconfig.py b/src/unstructured_client/models/shared/milvusdestinationconnectorconfig.py index 7f5d51c9..ce2b0464 100644 --- a/src/unstructured_client/models/shared/milvusdestinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/milvusdestinationconnectorconfig.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/milvusdestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/milvusdestinationconnectorconfiginput.py index ebb77945..b70e87dd 100644 --- a/src/unstructured_client/models/shared/milvusdestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/milvusdestinationconnectorconfiginput.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/outlooksourceconnectorconfig.py b/src/unstructured_client/models/shared/outlooksourceconnectorconfig.py index a65c5598..11daa6d1 100644 --- a/src/unstructured_client/models/shared/outlooksourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/outlooksourceconnectorconfig.py @@ -48,7 +48,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/outlooksourceconnectorconfiginput.py b/src/unstructured_client/models/shared/outlooksourceconnectorconfiginput.py index 56cf211b..2985423c 100644 --- a/src/unstructured_client/models/shared/outlooksourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/outlooksourceconnectorconfiginput.py @@ -48,7 +48,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/partition_parameters.py b/src/unstructured_client/models/shared/partition_parameters.py index f494c68d..fb636f6e 100644 --- a/src/unstructured_client/models/shared/partition_parameters.py +++ b/src/unstructured_client/models/shared/partition_parameters.py @@ -449,7 +449,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/postgressourceconnectorconfig.py b/src/unstructured_client/models/shared/postgressourceconnectorconfig.py index 67bd4b39..beec5558 100644 --- a/src/unstructured_client/models/shared/postgressourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/postgressourceconnectorconfig.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/postgressourceconnectorconfiginput.py b/src/unstructured_client/models/shared/postgressourceconnectorconfiginput.py index e093fb63..54e8af3a 100644 --- a/src/unstructured_client/models/shared/postgressourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/postgressourceconnectorconfiginput.py @@ -54,7 +54,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/redisdestinationconnectorconfig.py b/src/unstructured_client/models/shared/redisdestinationconnectorconfig.py index 0079acde..3ed5bd7c 100644 --- a/src/unstructured_client/models/shared/redisdestinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/redisdestinationconnectorconfig.py @@ -50,7 +50,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/redisdestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/redisdestinationconnectorconfiginput.py index 5c92fd52..a5aa50b5 100644 --- a/src/unstructured_client/models/shared/redisdestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/redisdestinationconnectorconfiginput.py @@ -59,7 +59,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/s3destinationconnectorconfig.py b/src/unstructured_client/models/shared/s3destinationconnectorconfig.py index 9fb23642..a9fe8a46 100644 --- a/src/unstructured_client/models/shared/s3destinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/s3destinationconnectorconfig.py @@ -44,7 +44,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/s3destinationconnectorconfiginput.py b/src/unstructured_client/models/shared/s3destinationconnectorconfiginput.py index 6f39a9fb..dbdbb364 100644 --- a/src/unstructured_client/models/shared/s3destinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/s3destinationconnectorconfiginput.py @@ -45,7 +45,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/s3sourceconnectorconfig.py b/src/unstructured_client/models/shared/s3sourceconnectorconfig.py index 11b70658..552f73fd 100644 --- a/src/unstructured_client/models/shared/s3sourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/s3sourceconnectorconfig.py @@ -47,7 +47,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/s3sourceconnectorconfiginput.py b/src/unstructured_client/models/shared/s3sourceconnectorconfiginput.py index c3150b07..7d796a91 100644 --- a/src/unstructured_client/models/shared/s3sourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/s3sourceconnectorconfiginput.py @@ -55,7 +55,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/sharepointsourceconnectorconfig.py b/src/unstructured_client/models/shared/sharepointsourceconnectorconfig.py index 1ec70918..d56f5e57 100644 --- a/src/unstructured_client/models/shared/sharepointsourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/sharepointsourceconnectorconfig.py @@ -51,7 +51,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/sharepointsourceconnectorconfiginput.py b/src/unstructured_client/models/shared/sharepointsourceconnectorconfiginput.py index c9ce9003..cfcadaf1 100644 --- a/src/unstructured_client/models/shared/sharepointsourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/sharepointsourceconnectorconfiginput.py @@ -51,7 +51,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/snowflakedestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/snowflakedestinationconnectorconfiginput.py index ff95a0a4..eceda64c 100644 --- a/src/unstructured_client/models/shared/snowflakedestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/snowflakedestinationconnectorconfiginput.py @@ -67,7 +67,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/snowflakesourceconnectorconfiginput.py b/src/unstructured_client/models/shared/snowflakesourceconnectorconfiginput.py index 7b7c1e97..792d8462 100644 --- a/src/unstructured_client/models/shared/snowflakesourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/snowflakesourceconnectorconfiginput.py @@ -64,7 +64,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/sourceconnectorinformation.py b/src/unstructured_client/models/shared/sourceconnectorinformation.py index 427cff25..6d7f3736 100644 --- a/src/unstructured_client/models/shared/sourceconnectorinformation.py +++ b/src/unstructured_client/models/shared/sourceconnectorinformation.py @@ -181,7 +181,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/updatedestinationconnector.py b/src/unstructured_client/models/shared/updatedestinationconnector.py index c0499187..fd446c49 100644 --- a/src/unstructured_client/models/shared/updatedestinationconnector.py +++ b/src/unstructured_client/models/shared/updatedestinationconnector.py @@ -9,6 +9,10 @@ AzureAISearchConnectorConfigInput, AzureAISearchConnectorConfigInputTypedDict, ) +from .azuredestinationconnectorconfiginput import ( + AzureDestinationConnectorConfigInput, + AzureDestinationConnectorConfigInputTypedDict, +) from .couchbasedestinationconnectorconfiginput import ( CouchbaseDestinationConnectorConfigInput, CouchbaseDestinationConnectorConfigInputTypedDict, @@ -91,20 +95,21 @@ Union[ GCSDestinationConnectorConfigInputTypedDict, ElasticsearchConnectorConfigInputTypedDict, + MongoDBConnectorConfigInputTypedDict, AzureAISearchConnectorConfigInputTypedDict, WeaviateDestinationConnectorConfigInputTypedDict, - MongoDBConnectorConfigInputTypedDict, DeltaTableConnectorConfigInputTypedDict, QdrantCloudDestinationConnectorConfigInputTypedDict, PineconeDestinationConnectorConfigInputTypedDict, + AzureDestinationConnectorConfigInputTypedDict, Neo4jDestinationConnectorConfigInputTypedDict, OneDriveDestinationConnectorConfigInputTypedDict, S3DestinationConnectorConfigInputTypedDict, AstraDBConnectorConfigInputTypedDict, - MilvusDestinationConnectorConfigInputTypedDict, - DatabricksVolumesConnectorConfigInputTypedDict, PostgresDestinationConnectorConfigInputTypedDict, + MilvusDestinationConnectorConfigInputTypedDict, KafkaCloudDestinationConnectorConfigInputTypedDict, + DatabricksVolumesConnectorConfigInputTypedDict, CouchbaseDestinationConnectorConfigInputTypedDict, RedisDestinationConnectorConfigInputTypedDict, DatabricksVDTDestinationConnectorConfigInputTypedDict, @@ -118,20 +123,21 @@ Union[ GCSDestinationConnectorConfigInput, ElasticsearchConnectorConfigInput, + MongoDBConnectorConfigInput, AzureAISearchConnectorConfigInput, WeaviateDestinationConnectorConfigInput, - MongoDBConnectorConfigInput, DeltaTableConnectorConfigInput, QdrantCloudDestinationConnectorConfigInput, PineconeDestinationConnectorConfigInput, + AzureDestinationConnectorConfigInput, Neo4jDestinationConnectorConfigInput, OneDriveDestinationConnectorConfigInput, S3DestinationConnectorConfigInput, AstraDBConnectorConfigInput, - MilvusDestinationConnectorConfigInput, - DatabricksVolumesConnectorConfigInput, PostgresDestinationConnectorConfigInput, + MilvusDestinationConnectorConfigInput, KafkaCloudDestinationConnectorConfigInput, + DatabricksVolumesConnectorConfigInput, CouchbaseDestinationConnectorConfigInput, RedisDestinationConnectorConfigInput, DatabricksVDTDestinationConnectorConfigInput, diff --git a/src/unstructured_client/models/shared/updateworkflow.py b/src/unstructured_client/models/shared/updateworkflow.py index e11b73bf..d4824c42 100644 --- a/src/unstructured_client/models/shared/updateworkflow.py +++ b/src/unstructured_client/models/shared/updateworkflow.py @@ -76,7 +76,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/weaviatedestinationconnectorconfig.py b/src/unstructured_client/models/shared/weaviatedestinationconnectorconfig.py index 3ec720e7..0058b6e7 100644 --- a/src/unstructured_client/models/shared/weaviatedestinationconnectorconfig.py +++ b/src/unstructured_client/models/shared/weaviatedestinationconnectorconfig.py @@ -35,7 +35,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/weaviatedestinationconnectorconfiginput.py b/src/unstructured_client/models/shared/weaviatedestinationconnectorconfiginput.py index 11ba52b0..1f61f6dd 100644 --- a/src/unstructured_client/models/shared/weaviatedestinationconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/weaviatedestinationconnectorconfiginput.py @@ -35,7 +35,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/workflowinformation.py b/src/unstructured_client/models/shared/workflowinformation.py index 7e6e6ffa..73bbce0b 100644 --- a/src/unstructured_client/models/shared/workflowinformation.py +++ b/src/unstructured_client/models/shared/workflowinformation.py @@ -62,7 +62,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/workflownode.py b/src/unstructured_client/models/shared/workflownode.py index 3f70e2e1..87d22acc 100644 --- a/src/unstructured_client/models/shared/workflownode.py +++ b/src/unstructured_client/models/shared/workflownode.py @@ -43,7 +43,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/zendesksourceconnectorconfig.py b/src/unstructured_client/models/shared/zendesksourceconnectorconfig.py index 5b0419b0..f067ff5a 100644 --- a/src/unstructured_client/models/shared/zendesksourceconnectorconfig.py +++ b/src/unstructured_client/models/shared/zendesksourceconnectorconfig.py @@ -41,7 +41,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/models/shared/zendesksourceconnectorconfiginput.py b/src/unstructured_client/models/shared/zendesksourceconnectorconfiginput.py index 57124521..a7ac9860 100644 --- a/src/unstructured_client/models/shared/zendesksourceconnectorconfiginput.py +++ b/src/unstructured_client/models/shared/zendesksourceconnectorconfiginput.py @@ -41,7 +41,7 @@ def serialize_model(self, handler): m = {} - for n, f in self.model_fields.items(): + for n, f in type(self).model_fields.items(): k = f.alias or n val = serialized.get(k) serialized.pop(k, None) diff --git a/src/unstructured_client/utils/enums.py b/src/unstructured_client/utils/enums.py index c650b10c..c3bc13cf 100644 --- a/src/unstructured_client/utils/enums.py +++ b/src/unstructured_client/utils/enums.py @@ -1,34 +1,74 @@ """Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.""" import enum - +import sys class OpenEnumMeta(enum.EnumMeta): - def __call__( - cls, value, names=None, *, module=None, qualname=None, type=None, start=1 - ): - # The `type` kwarg also happens to be a built-in that pylint flags as - # redeclared. Safe to ignore this lint rule with this scope. - # pylint: disable=redefined-builtin + # The __call__ method `boundary` kwarg was added in 3.11 and must be present + # for pyright. Refer also: https://github.com/pylint-dev/pylint/issues/9622 + # pylint: disable=unexpected-keyword-arg + # The __call__ method `values` varg must be named for pyright. + # pylint: disable=keyword-arg-before-vararg + + if sys.version_info >= (3, 11): + def __call__( + cls, value, names=None, *values, module=None, qualname=None, type=None, start=1, boundary=None + ): + # The `type` kwarg also happens to be a built-in that pylint flags as + # redeclared. Safe to ignore this lint rule with this scope. + # pylint: disable=redefined-builtin + + if names is not None: + return super().__call__( + value, + names=names, + *values, + module=module, + qualname=qualname, + type=type, + start=start, + boundary=boundary, + ) + + try: + return super().__call__( + value, + names=names, # pyright: ignore[reportArgumentType] + *values, + module=module, + qualname=qualname, + type=type, + start=start, + boundary=boundary, + ) + except ValueError: + return value + else: + def __call__( + cls, value, names=None, *, module=None, qualname=None, type=None, start=1 + ): + # The `type` kwarg also happens to be a built-in that pylint flags as + # redeclared. Safe to ignore this lint rule with this scope. + # pylint: disable=redefined-builtin - if names is not None: - return super().__call__( - value, - names=names, - module=module, - qualname=qualname, - type=type, - start=start, - ) + if names is not None: + return super().__call__( + value, + names=names, + module=module, + qualname=qualname, + type=type, + start=start, + ) - try: - return super().__call__( - value, - names=names, # pyright: ignore[reportArgumentType] - module=module, - qualname=qualname, - type=type, - start=start, - ) - except ValueError: - return value + try: + return super().__call__( + value, + names=names, # pyright: ignore[reportArgumentType] + module=module, + qualname=qualname, + type=type, + start=start, + ) + except ValueError: + return value