Merge pull request #31 from airbytehq/speakeasy-sdk-regen-1689153495

terencecho · web-flow · commit ce88fa6ac576 · 2023-07-20T09:11:02.000-07:00
chore: speakeasy sdk regeneration - Generate
diff --git a/README.md b/README.md
@@ -23,6 +23,8 @@ pip install airbyte-api
 
 ## SDK Example Usage
 <!-- Start SDK Example Usage -->
+
+
 ```python
 import airbyte
 from airbyte.models import shared
diff --git a/RELEASES.md b/RELEASES.md
@@ -326,4 +326,44 @@ Based on:
 - OpenAPI Doc 1.0.0 
 - Speakeasy CLI 1.56.0 (2.61.0) https://github.com/speakeasy-api/speakeasy
 ### Releases
-- [PyPI v0.21.0] https://pypi.org/project/airbyte-api/0.21.0 - .
+- [PyPI v0.21.0] https://pypi.org/project/airbyte-api/0.21.0 - .
+
+## 2023-07-12 09:18:13
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 
+- Speakeasy CLI 1.56.4 (2.61.5) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.21.1] https://pypi.org/project/airbyte-api/0.21.1 - .
+
+## 2023-07-13 00:16:36
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 
+- Speakeasy CLI 1.57.0 (2.62.1) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.22.0] https://pypi.org/project/airbyte-api/0.22.0 - .
+
+## 2023-07-14 00:16:28
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 
+- Speakeasy CLI 1.59.0 (2.65.0) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.23.0] https://pypi.org/project/airbyte-api/0.23.0 - .
+
+## 2023-07-18 00:23:32
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 
+- Speakeasy CLI 1.61.0 (2.70.0) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.24.0] https://pypi.org/project/airbyte-api/0.24.0 - .
+
+## 2023-07-19 00:22:38
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 
+- Speakeasy CLI 1.62.1 (2.70.2) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.24.1] https://pypi.org/project/airbyte-api/0.24.1 - .
diff --git a/USAGE.md b/USAGE.md
@@ -1,4 +1,6 @@
 <!-- Start SDK Example Usage -->
+
+
 ```python
 import airbyte
 from airbyte.models import shared
diff --git a/docs/sdks/connections/README.md b/docs/sdks/connections/README.md
@@ -100,7 +100,7 @@ Delete a Connection
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -138,7 +138,7 @@ Get Connection details
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -176,7 +176,7 @@ List connections
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
diff --git a/docs/sdks/destinations/README.md b/docs/sdks/destinations/README.md
@@ -67,7 +67,7 @@ Delete a Destination
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -105,7 +105,7 @@ Get Destination details
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -143,7 +143,7 @@ List destinations
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
diff --git a/docs/sdks/jobs/README.md b/docs/sdks/jobs/README.md
@@ -15,7 +15,7 @@ Cancel a running Job
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -92,7 +92,7 @@ Get Job status and details
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
diff --git a/docs/sdks/sources/README.md b/docs/sdks/sources/README.md
@@ -65,7 +65,7 @@ Delete a Source
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -103,7 +103,7 @@ Get Source details
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -186,7 +186,7 @@ List sources
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
diff --git a/docs/sdks/streams/README.md b/docs/sdks/streams/README.md
@@ -12,7 +12,7 @@ Get stream properties
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
diff --git a/docs/sdks/workspaces/README.md b/docs/sdks/workspaces/README.md
@@ -106,7 +106,7 @@ Delete a Workspace
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -144,7 +144,7 @@ Get Workspace details
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
@@ -182,7 +182,7 @@ List workspaces
 
 ```python
 import airbyte
-from airbyte.models import operations
+from airbyte.models import operations, shared
 
 s = airbyte.Airbyte(
     security=shared.Security(
diff --git a/files.gen b/files.gen
@@ -10,6 +10,7 @@ pylintrc
 setup.py
 src/airbyte/__init__.py
 src/airbyte/models/__init__.py
+src/airbyte/models/errors/sdkerror.py
 src/airbyte/utils/__init__.py
 src/airbyte/utils/retries.py
 src/airbyte/utils/utils.py
@@ -365,6 +366,7 @@ src/airbyte/models/shared/workspacesresponse.py
 src/airbyte/models/shared/workspaceupdaterequest.py
 src/airbyte/models/shared/security.py
 src/airbyte/models/shared/__init__.py
+src/airbyte/models/errors/__init__.py
 docs/sdks/airbyte/README.md
 docs/sdks/connections/README.md
 docs/sdks/destinations/README.md
diff --git a/gen.yaml b/gen.yaml
@@ -2,8 +2,8 @@ configVersion: 1.0.0
 management:
   docChecksum: bb2011e16a0ec78eb8a13a803e08b4aa
   docVersion: 1.0.0
-  speakeasyVersion: 1.56.0
-  generationVersion: 2.61.0
+  speakeasyVersion: 1.62.1
+  generationVersion: 2.70.2
 generation:
   comments:
     disableComments: false
@@ -14,7 +14,7 @@ generation:
   tagNamespacingDisabled: false
   telemetryEnabled: true
 python:
-  version: 0.21.0
+  version: 0.24.1
   author: Airbyte
   description: Python Client SDK for Airbyte API
   maxMethodParams: 0
diff --git a/pylintrc b/pylintrc
@@ -438,7 +438,9 @@ disable=raw-checker-failed,
         using-constant-test,
         too-many-statements,
         cyclic-import,
-        too-many-nested-blocks
+        too-many-nested-blocks,
+        too-many-boolean-expressions,
+        no-else-raise
 
 # Enable the message, report, category or checker with the given id(s). You can
 # either give multiple identifier separated by comma (,) or put this option
diff --git a/setup.py b/setup.py
@@ -10,7 +10,7 @@
 
 setuptools.setup(
     name="airbyte-api",
-    version="0.21.0",
+    version="0.24.1",
     author="Airbyte",
     description="Python Client SDK for Airbyte API",
     long_description=long_description,
diff --git a/src/airbyte/connections.py b/src/airbyte/connections.py
@@ -2,7 +2,7 @@
 
 from .sdkconfiguration import SDKConfiguration
 from airbyte import utils
-from airbyte.models import operations, shared
+from airbyte.models import errors, operations, shared
 from typing import Optional
 
 class Connections:
@@ -37,6 +37,8 @@ def create_connection(self, request: shared.ConnectionCreateRequest) -> operatio
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.ConnectionResponse])
                 res.connection_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [400, 403]:
             pass
 
@@ -83,6 +85,8 @@ def get_connection(self, request: operations.GetConnectionRequest) -> operations
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.ConnectionResponse])
                 res.connection_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -110,6 +114,8 @@ def list_connections(self, request: operations.ListConnectionsRequest) -> operat
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.ConnectionsResponse])
                 res.connections_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -141,6 +147,8 @@ def patch_connection(self, request: operations.PatchConnectionRequest) -> operat
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.ConnectionResponse])
                 res.connection_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
diff --git a/src/airbyte/destinations.py b/src/airbyte/destinations.py
@@ -2,7 +2,7 @@
 
 from .sdkconfiguration import SDKConfiguration
 from airbyte import utils
-from airbyte.models import operations, shared
+from airbyte.models import errors, operations, shared
 from typing import Optional
 
 class Destinations:
@@ -37,6 +37,8 @@ def create_destination(self, request: shared.DestinationCreateRequest) -> operat
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.DestinationResponse])
                 res.destination_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [400, 403, 404]:
             pass
 
@@ -83,6 +85,8 @@ def get_destination(self, request: operations.GetDestinationRequest) -> operatio
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.DestinationResponse])
                 res.destination_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -110,6 +114,8 @@ def list_destinations(self, request: operations.ListDestinationsRequest) -> oper
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.DestinationsResponse])
                 res.destinations_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -139,6 +145,8 @@ def patch_destination(self, request: operations.PatchDestinationRequest) -> oper
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.DestinationResponse])
                 res.destination_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -168,6 +176,8 @@ def put_destination(self, request: operations.PutDestinationRequest) -> operatio
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.DestinationResponse])
                 res.destination_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
diff --git a/src/airbyte/jobs.py b/src/airbyte/jobs.py
@@ -2,7 +2,7 @@
 
 from .sdkconfiguration import SDKConfiguration
 from airbyte import utils
-from airbyte.models import operations, shared
+from airbyte.models import errors, operations, shared
 from typing import Optional
 
 class Jobs:
@@ -32,6 +32,8 @@ def cancel_job(self, request: operations.CancelJobRequest) -> operations.CancelJ
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.JobResponse])
                 res.job_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -63,6 +65,8 @@ def create_job(self, request: shared.JobCreateRequest) -> operations.CreateJobRe
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.JobResponse])
                 res.job_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [400, 403]:
             pass
 
@@ -89,6 +93,8 @@ def get_job(self, request: operations.GetJobRequest) -> operations.GetJobRespons
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.JobResponse])
                 res.job_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code in [403, 404]:
             pass
 
@@ -116,6 +122,8 @@ def list_jobs(self, request: operations.ListJobsRequest) -> operations.ListJobsR
             if utils.match_content_type(content_type, 'application/json'):
                 out = utils.unmarshal_json(http_res.text, Optional[shared.JobsResponse])
                 res.jobs_response = out
+            else:
+                raise errors.SDKError(f'unknown content-type received: {content_type}', http_res.status_code, http_res.text, http_res)
         elif http_res.status_code == 403:
             pass
 
diff --git a/src/airbyte/models/errors/__init__.py b/src/airbyte/models/errors/__init__.py
diff --git a/src/airbyte/models/errors/sdkerror.py b/src/airbyte/models/errors/sdkerror.py
diff --git a/src/airbyte/models/shared/source_facebook_marketing.py b/src/airbyte/models/shared/source_facebook_marketing.py
diff --git a/src/airbyte/sdkconfiguration.py b/src/airbyte/sdkconfiguration.py
diff --git a/src/airbyte/sources.py b/src/airbyte/sources.py
diff --git a/src/airbyte/streams.py b/src/airbyte/streams.py
diff --git a/src/airbyte/workspaces.py b/src/airbyte/workspaces.py
