Merge pull request #6 from airbytehq/speakeasy-sdk-regen-1682374952

chore: speakeasy sdk regeneration - Generate

Author: bgroff

README.md

@@ -21,7 +21,7 @@ The Developer Portal UI can also be used to help build your integration by showi
 ## SDK Installation
 
 ```bash
-pip install airbyte
+pip install airbyte-api
 ```
 <!-- End SDK Installation -->
 
@@ -151,7 +151,7 @@ if res.connection_response is not None:
 * `create_source` - Create a source
 * `delete_source` - Delete a Source
 * `get_source` - Get Source details
-* `initiate_o_auth` - Initiate OAuth for a source.
+* `initiate_o_auth` - Initiate OAuth for a source
 * `list_sources` - List sources
 
 ### streams
@@ -160,8 +160,8 @@ if res.connection_response is not None:
 
 ### workspaces
 
+* `create_or_update_workspace_o_auth_credentials` - Create OAuth override credentials for a workspace and source type.
 * `create_workspace` - Create a workspace
-* `delete_workspace` - Delete a Workspace
 * `get_workspace` - Get Workspace details
 * `list_workspaces` - List workspaces
 <!-- End SDK Available Operations -->

RELEASES.md

@@ -54,4 +54,12 @@ Based on:
 - OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download
 - Speakeasy CLI 1.20.2 (2.18.2) https://github.com/speakeasy-api/speakeasy
 ### Releases
-- [PyPI v0.0.1] https://pypi.org/project/airbyte/0.0.1 - .
+- [PyPI v0.0.1] https://pypi.org/project/airbyte/0.0.1 - .
+
+## 2023-04-24 22:22:31
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download
+- Speakeasy CLI 1.22.2 (2.20.1) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.1.0] https://pypi.org/project/airbyte-api/0.1.0 - .

files.gen

@@ -30,8 +30,8 @@ src/airbyte/models/operations/getsource.py
 src/airbyte/models/operations/initiateoauth.py
 src/airbyte/models/operations/listsources.py
 src/airbyte/models/operations/getstreamproperties.py
+src/airbyte/models/operations/createorupdateworkspaceoauthcredentials.py
 src/airbyte/models/operations/createworkspace.py
-src/airbyte/models/operations/deleteworkspace.py
 src/airbyte/models/operations/getworkspace.py
 src/airbyte/models/operations/listworkspaces.py
 src/airbyte/models/operations/__init__.py
@@ -284,10 +284,10 @@ src/airbyte/models/shared/source_zenloop.py
 src/airbyte/models/shared/source_zoho_crm.py
 src/airbyte/models/shared/source_zoom.py
 src/airbyte/models/shared/source_zuora.py
-src/airbyte/models/shared/initiateoauthresponse.py
 src/airbyte/models/shared/initiateoauthrequest.py
 src/airbyte/models/shared/sourcesresponse.py
 src/airbyte/models/shared/streamproperties.py
+src/airbyte/models/shared/workspaceoauthcredentialsrequest.py
 src/airbyte/models/shared/workspaceresponse.py
 src/airbyte/models/shared/workspacecreaterequest.py
 src/airbyte/models/shared/workspacesresponse.py

gen.yaml

@@ -1,16 +1,15 @@
 configVersion: 1.0.0
 management:
-  docChecksum: 9a5d0cf1d2ebcbce14777ece8db4ccc2
+  docChecksum: b33273ead3e10c4bc4f9bfeed6ad97a4
   docVersion: 1.0.0
-  speakeasyVersion: 1.20.2
-  generationVersion: 2.18.2
+  speakeasyVersion: 1.22.2
+  generationVersion: 2.20.1
 generation:
   telemetryEnabled: true
   sdkClassName: airbyte
-  sdkFlattening: true
   singleTagPerOp: false
 python:
-  version: ""
+  version: 0.1.0
   author: Airbyte
   description: Python Client SDK for Airbyte API
   packageName: airbyte-api

setup.py

@@ -9,8 +9,8 @@
     long_description = ""
 
 setuptools.setup(
-    name="airbyte",
-    version="0.0.1",
+    name="airbyte-api",
+    version="0.1.0",
     author="Airbyte",
     description="Python Client SDK for Airbyte API",
     long_description=long_description,

src/airbyte/connections.py

@@ -33,6 +33,7 @@ def create_connection(self, request: shared.ConnectionCreateRequest) -> operatio
             headers['content-type'] = req_content_type
         if data is None and form is None:
             raise Exception('request body is required')
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
@@ -56,10 +57,12 @@ def delete_connection(self, request: operations.DeleteConnectionRequest) -> oper
 
         url = utils.generate_url(operations.DeleteConnectionRequest, base_url, '/connections/{connectionId}', request)
 
+        headers = {}
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('DELETE', url)
+        http_res = client.request('DELETE', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.DeleteConnectionResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)
@@ -73,10 +76,12 @@ def get_connection(self, request: operations.GetConnectionRequest) -> operations
 
         url = utils.generate_url(operations.GetConnectionRequest, base_url, '/connections/{connectionId}', request)
 
+        headers = {}
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('GET', url)
+        http_res = client.request('GET', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.GetConnectionResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)
@@ -96,11 +101,13 @@ def list_connections(self, request: operations.ListConnectionsRequest) -> operat
 
         url = base_url.removesuffix('/') + '/connections'
 
+        headers = {}
         query_params = utils.get_query_params(operations.ListConnectionsRequest, request)
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('GET', url, params=query_params)
+        http_res = client.request('GET', url, params=query_params, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.ListConnectionsResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)

src/airbyte/destinations.py

@@ -33,6 +33,7 @@ def create_destination(self, request: shared.DestinationCreateRequest) -> operat
         req_content_type, data, form = utils.serialize_request_body(request, "request", 'json')
         if req_content_type not in ('multipart/form-data', 'multipart/mixed'):
             headers['content-type'] = req_content_type
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
@@ -56,10 +57,12 @@ def delete_destination(self, request: operations.DeleteDestinationRequest) -> op
 
         url = utils.generate_url(operations.DeleteDestinationRequest, base_url, '/destinations/{destinationId}', request)
 
+        headers = {}
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('DELETE', url)
+        http_res = client.request('DELETE', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.DeleteDestinationResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)
@@ -73,10 +76,12 @@ def get_destination(self, request: operations.GetDestinationRequest) -> operatio
 
         url = utils.generate_url(operations.GetDestinationRequest, base_url, '/destinations/{destinationId}', request)
 
+        headers = {}
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('GET', url)
+        http_res = client.request('GET', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.GetDestinationResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)
@@ -96,11 +101,13 @@ def list_destinations(self, request: operations.ListDestinationsRequest) -> oper
 
         url = base_url.removesuffix('/') + '/destinations'
 
+        headers = {}
         query_params = utils.get_query_params(operations.ListDestinationsRequest, request)
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('GET', url, params=query_params)
+        http_res = client.request('GET', url, params=query_params, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.ListDestinationsResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)

src/airbyte/jobs.py

@@ -27,10 +27,12 @@ def cancel_job(self, request: operations.CancelJobRequest) -> operations.CancelJ
 
         url = utils.generate_url(operations.CancelJobRequest, base_url, '/jobs/{jobId}', request)
 
+        headers = {}
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('DELETE', url)
+        http_res = client.request('DELETE', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.CancelJobResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)
@@ -56,6 +58,7 @@ def create_job(self, request: shared.JobCreateRequest) -> operations.CreateJobRe
             headers['content-type'] = req_content_type
         if data is None and form is None:
             raise Exception('request body is required')
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
@@ -79,10 +82,12 @@ def get_job(self, request: operations.GetJobRequest) -> operations.GetJobRespons
 
         url = utils.generate_url(operations.GetJobRequest, base_url, '/jobs/{jobId}', request)
 
+        headers = {}
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('GET', url)
+        http_res = client.request('GET', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.GetJobResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)
@@ -102,11 +107,13 @@ def list_jobs(self, request: operations.ListJobsRequest) -> operations.ListJobsR
 
         url = base_url.removesuffix('/') + '/jobs'
 
+        headers = {}
         query_params = utils.get_query_params(operations.ListJobsRequest, request)
+        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
 
         client = self._security_client
 
-        http_res = client.request('GET', url, params=query_params)
+        http_res = client.request('GET', url, params=query_params, headers=headers)
         content_type = http_res.headers.get('Content-Type')
 
         res = operations.ListJobsResponse(status_code=http_res.status_code, content_type=content_type, raw_response=http_res)

src/airbyte/models/operations/__init__.py

@@ -4,12 +4,12 @@
 from .createconnection import *
 from .createdestination import *
 from .createjob import *
+from .createorupdateworkspaceoauthcredentials import *
 from .createsource import *
 from .createworkspace import *
 from .deleteconnection import *
 from .deletedestination import *
 from .deletesource import *
-from .deleteworkspace import *
 from .getconnection import *
 from .getdestination import *
 from .getjob import *
@@ -23,4 +23,4 @@
 from .listsources import *
 from .listworkspaces import *
 
-__all__ = ["CancelJobRequest","CancelJobResponse","CreateConnectionResponse","CreateDestinationResponse","CreateJobResponse","CreateSourceResponse","CreateWorkspaceResponse","DeleteConnectionRequest","DeleteConnectionResponse","DeleteDestinationRequest","DeleteDestinationResponse","DeleteSourceRequest","DeleteSourceResponse","DeleteWorkspaceRequest","DeleteWorkspaceResponse","GetConnectionRequest","GetConnectionResponse","GetDestinationRequest","GetDestinationResponse","GetJobRequest","GetJobResponse","GetSourceRequest","GetSourceResponse","GetStreamPropertiesRequest","GetStreamPropertiesResponse","GetWorkspaceRequest","GetWorkspaceResponse","InitiateOAuthResponse","ListConnectionsRequest","ListConnectionsResponse","ListDestinationsRequest","ListDestinationsResponse","ListJobsRequest","ListJobsResponse","ListSourcesRequest","ListSourcesResponse","ListWorkspacesRequest","ListWorkspacesResponse"]
+__all__ = ["CancelJobRequest","CancelJobResponse","CreateConnectionResponse","CreateDestinationResponse","CreateJobResponse","CreateOrUpdateWorkspaceOAuthCredentialsRequest","CreateOrUpdateWorkspaceOAuthCredentialsResponse","CreateSourceResponse","CreateWorkspaceResponse","DeleteConnectionRequest","DeleteConnectionResponse","DeleteDestinationRequest","DeleteDestinationResponse","DeleteSourceRequest","DeleteSourceResponse","GetConnectionRequest","GetConnectionResponse","GetDestinationRequest","GetDestinationResponse","GetJobRequest","GetJobResponse","GetSourceRequest","GetSourceResponse","GetStreamPropertiesRequest","GetStreamPropertiesResponse","GetWorkspaceRequest","GetWorkspaceResponse","InitiateOAuthResponse","ListConnectionsRequest","ListConnectionsResponse","ListDestinationsRequest","ListDestinationsResponse","ListJobsRequest","ListJobsResponse","ListSourcesRequest","ListSourcesResponse","ListWorkspacesRequest","ListWorkspacesResponse"]

src/airbyte/models/operations/deleteworkspace.py renamed to src/airbyte/models/operations/createorupdateworkspaceoauthcredentials.py

@@ -3,17 +3,19 @@
 from __future__ import annotations
 import dataclasses
 import requests as requests_http
+from ..shared import workspaceoauthcredentialsrequest as shared_workspaceoauthcredentialsrequest
 from typing import Optional
 
 
 @dataclasses.dataclass
-class DeleteWorkspaceRequest:
+class CreateOrUpdateWorkspaceOAuthCredentialsRequest:
 
     workspace_id: str = dataclasses.field(metadata={'path_param': { 'field_name': 'workspaceId', 'style': 'simple', 'explode': False }})  
+    workspace_o_auth_credentials_request: shared_workspaceoauthcredentialsrequest.WorkspaceOAuthCredentialsRequest = dataclasses.field(metadata={'request': { 'media_type': 'application/json' }})  
 
 
 @dataclasses.dataclass
-class DeleteWorkspaceResponse:
+class CreateOrUpdateWorkspaceOAuthCredentialsResponse:
 
     content_type: str = dataclasses.field()  
     status_code: int = dataclasses.field()  

src/airbyte/models/operations/initiateoauth.py

@@ -3,7 +3,6 @@
 from __future__ import annotations
 import dataclasses
 import requests as requests_http
-from ..shared import initiateoauthresponse as shared_initiateoauthresponse
 from typing import Optional
 
 
@@ -12,7 +11,5 @@ class InitiateOAuthResponse:
 
     content_type: str = dataclasses.field()  
     status_code: int = dataclasses.field()  
-    initiate_oauth_response: Optional[shared_initiateoauthresponse.InitiateOauthResponse] = dataclasses.field(default=None)
-    r"""The result of creating an OAuth link"""  
     raw_response: Optional[requests_http.Response] = dataclasses.field(default=None)  
 

src/airbyte/models/shared/__init__.py

@@ -12,12 +12,12 @@
 class InitiateOauthRequest:
     r"""POST body for initiating OAuth via the public API"""
 
+    name: str = dataclasses.field(metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('name') }})
+    r"""The name of the source to authenticate to"""  
     redirect_url: str = dataclasses.field(metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('redirectUrl') }})
     r"""The URL to redirect the user to with the OAuth secret stored in the secret_id query string parameter after authentication is complete."""  
-    name: Optional[str] = dataclasses.field(default=None, metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('name'), 'exclude': lambda f: f is None }})
-    r"""The name of the source to authenticate to"""  
+    workspace_id: str = dataclasses.field(metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('workspaceId') }})
+    r"""The workspace to create the secret and eventually the full source."""  
     o_auth_input_configuration: Optional[dict[str, Any]] = dataclasses.field(default=None, metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('oAuthInputConfiguration'), 'exclude': lambda f: f is None }})
     r"""Arbitrary vars to pass for OAuth depending on what the source/destination spec requires."""  
-    workspace_id: Optional[str] = dataclasses.field(default=None, metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('workspaceId'), 'exclude': lambda f: f is None }})
-    r"""The workspace to create the secret and eventually the full source."""  
 

src/airbyte/models/shared/initiateoauthrequest.py

@@ -2,9 +2,12 @@
 
 from __future__ import annotations
 import dataclasses
+import dateutil.parser
 from airbyte import utils
 from dataclasses_json import Undefined, dataclass_json
+from datetime import datetime
 from enum import Enum
+from marshmallow import fields
 from typing import Any, Optional
 
 class SourceS3FormatJsonlFiletypeEnum(str, Enum):
@@ -105,6 +108,8 @@ class SourceS3S3AmazonWebServices:
     r"""Endpoint to an S3 compatible service. Leave empty to use AWS."""  
     path_prefix: Optional[str] = dataclasses.field(default=None, metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('path_prefix'), 'exclude': lambda f: f is None }})
     r"""By providing a path-like prefix (e.g. myFolder/thisTable/) under which all the relevant files sit, we can optimize finding these in S3. This is optional but recommended if your bucket contains many folders/files which you don't need to replicate."""  
+    start_date: Optional[datetime] = dataclasses.field(default=None, metadata={'dataclasses_json': { 'letter_case': utils.get_field_name('start_date'), 'encoder': utils.datetimeisoformat(True), 'decoder': dateutil.parser.isoparse, 'mm_field': fields.DateTime(format='iso'), 'exclude': lambda f: f is None }})
+    r"""UTC date and time in the format 2017-01-25T00:00:00Z. Any file modified before this date will not be replicated."""  
 
 class SourceS3S3Enum(str, Enum):
     S3 = 's3'