ci: regenerated with OpenAPI Doc 1.0.0, Speakeay CLI 1.43.0

Author: speakeasybot

RELEASES.md

@@ -190,4 +190,12 @@ Based on:
 - OpenAPI Doc 1.0.0 
 - Speakeasy CLI 1.40.3 (2.34.7) https://github.com/speakeasy-api/speakeasy
 ### Releases
-- [PyPI v0.11.3] https://pypi.org/project/airbyte-api/0.11.3 - .
+- [PyPI v0.11.3] https://pypi.org/project/airbyte-api/0.11.3 - .
+
+## 2023-06-03 00:13:54
+### Changes
+Based on:
+- OpenAPI Doc 1.0.0 
+- Speakeasy CLI 1.43.0 (2.35.3) https://github.com/speakeasy-api/speakeasy
+### Releases
+- [PyPI v0.12.0] https://pypi.org/project/airbyte-api/0.12.0 - .

files.gen

@@ -1,3 +1,4 @@
+src/airbyte/sdkconfiguration.py
 src/airbyte/connections.py
 src/airbyte/destinations.py
 src/airbyte/jobs.py

gen.yaml

@@ -2,14 +2,14 @@ configVersion: 1.0.0
 management:
   docChecksum: e82f3e11abf47c2509f115468e75bb06
   docVersion: 1.0.0
-  speakeasyVersion: 1.40.3
-  generationVersion: 2.34.7
+  speakeasyVersion: 1.43.0
+  generationVersion: 2.35.3
 generation:
   sdkClassName: airbyte
   singleTagPerOp: false
   telemetryEnabled: true
 python:
-  version: 0.11.3
+  version: 0.12.0
   author: Airbyte
   description: Python Client SDK for Airbyte API
   maxMethodParams: 0

setup.py

@@ -10,7 +10,7 @@
 
 setuptools.setup(
     name="airbyte-api",
-    version="0.11.3",
+    version="0.12.0",
     author="Airbyte",
     description="Python Client SDK for Airbyte API",
     long_description=long_description,

src/airbyte/__init__.py

@@ -1,3 +1,4 @@
 """Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT."""
 
 from .sdk import *
+from .sdkconfiguration import *

src/airbyte/connections.py

@@ -1,42 +1,32 @@
 """Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT."""
 
-import requests as requests_http
-from . import utils
+from .sdkconfiguration import SDKConfiguration
+from airbyte import utils
 from airbyte.models import operations, shared
 from typing import Optional
 
 class Connections:
-    _client: requests_http.Session
-    _security_client: requests_http.Session
-    _server_url: str
-    _language: str
-    _sdk_version: str
-    _gen_version: str
+    sdk_configuration: SDKConfiguration
 
-    def __init__(self, client: requests_http.Session, security_client: requests_http.Session, server_url: str, language: str, sdk_version: str, gen_version: str) -> None:
-        self._client = client
-        self._security_client = security_client
-        self._server_url = server_url
-        self._language = language
-        self._sdk_version = sdk_version
-        self._gen_version = gen_version
+    def __init__(self, sdk_config: SDKConfiguration) -> None:
+        self.sdk_configuration = sdk_config
 
 
     def create_connection(self, request: shared.ConnectionCreateRequest) -> operations.CreateConnectionResponse:
         r"""Create a connection"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
-        url = base_url.removesuffix('/') + '/connections'
+        url = base_url + '/connections'
         headers = {}
         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
         if data is None and form is None:
             raise Exception('request body is required')
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('POST', url, data=data, files=form, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -55,14 +45,14 @@ def create_connection(self, request: shared.ConnectionCreateRequest) -> operatio
 
     def delete_connection(self, request: operations.DeleteConnectionRequest) -> operations.DeleteConnectionResponse:
         r"""Delete a Connection"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
         url = utils.generate_url(operations.DeleteConnectionRequest, base_url, '/connections/{connectionId}', request)
         headers = {}
         headers['Accept'] = '*/*'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('DELETE', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -75,14 +65,14 @@ def delete_connection(self, request: operations.DeleteConnectionRequest) -> oper
 
     def get_connection(self, request: operations.GetConnectionRequest) -> operations.GetConnectionResponse:
         r"""Get Connection details"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
         url = utils.generate_url(operations.GetConnectionRequest, base_url, '/connections/{connectionId}', request)
         headers = {}
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('GET', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -101,15 +91,15 @@ def get_connection(self, request: operations.GetConnectionRequest) -> operations
 
     def list_connections(self, request: operations.ListConnectionsRequest) -> operations.ListConnectionsResponse:
         r"""List connections"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
-        url = base_url.removesuffix('/') + '/connections'
+        url = base_url + '/connections'
         headers = {}
         query_params = utils.get_query_params(operations.ListConnectionsRequest, request)
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('GET', url, params=query_params, headers=headers)
         content_type = http_res.headers.get('Content-Type')

src/airbyte/destinations.py

@@ -1,42 +1,32 @@
 """Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT."""
 
-import requests as requests_http
-from . import utils
+from .sdkconfiguration import SDKConfiguration
+from airbyte import utils
 from airbyte.models import operations, shared
 from typing import Optional
 
 class Destinations:
-    _client: requests_http.Session
-    _security_client: requests_http.Session
-    _server_url: str
-    _language: str
-    _sdk_version: str
-    _gen_version: str
+    sdk_configuration: SDKConfiguration
 
-    def __init__(self, client: requests_http.Session, security_client: requests_http.Session, server_url: str, language: str, sdk_version: str, gen_version: str) -> None:
-        self._client = client
-        self._security_client = security_client
-        self._server_url = server_url
-        self._language = language
-        self._sdk_version = sdk_version
-        self._gen_version = gen_version
+    def __init__(self, sdk_config: SDKConfiguration) -> None:
+        self.sdk_configuration = sdk_config
 
 
     def create_destination(self, request: shared.DestinationCreateRequest) -> operations.CreateDestinationResponse:
         r"""Create a destination
         Creates a destination given a name, workspace id, and a json blob containing the configuration for the source.
         """
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
-        url = base_url.removesuffix('/') + '/destinations'
+        url = base_url + '/destinations'
         headers = {}
         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['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('POST', url, data=data, files=form, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -55,14 +45,14 @@ def create_destination(self, request: shared.DestinationCreateRequest) -> operat
 
     def delete_destination(self, request: operations.DeleteDestinationRequest) -> operations.DeleteDestinationResponse:
         r"""Delete a Destination"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
         url = utils.generate_url(operations.DeleteDestinationRequest, base_url, '/destinations/{destinationId}', request)
         headers = {}
         headers['Accept'] = '*/*'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('DELETE', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -75,14 +65,14 @@ def delete_destination(self, request: operations.DeleteDestinationRequest) -> op
 
     def get_destination(self, request: operations.GetDestinationRequest) -> operations.GetDestinationResponse:
         r"""Get Destination details"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
         url = utils.generate_url(operations.GetDestinationRequest, base_url, '/destinations/{destinationId}', request)
         headers = {}
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('GET', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -101,15 +91,15 @@ def get_destination(self, request: operations.GetDestinationRequest) -> operatio
 
     def list_destinations(self, request: operations.ListDestinationsRequest) -> operations.ListDestinationsResponse:
         r"""List destinations"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
-        url = base_url.removesuffix('/') + '/destinations'
+        url = base_url + '/destinations'
         headers = {}
         query_params = utils.get_query_params(operations.ListDestinationsRequest, request)
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('GET', url, params=query_params, headers=headers)
         content_type = http_res.headers.get('Content-Type')

src/airbyte/jobs.py

@@ -1,37 +1,27 @@
 """Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT."""
 
-import requests as requests_http
-from . import utils
+from .sdkconfiguration import SDKConfiguration
+from airbyte import utils
 from airbyte.models import operations, shared
 from typing import Optional
 
 class Jobs:
-    _client: requests_http.Session
-    _security_client: requests_http.Session
-    _server_url: str
-    _language: str
-    _sdk_version: str
-    _gen_version: str
+    sdk_configuration: SDKConfiguration
 
-    def __init__(self, client: requests_http.Session, security_client: requests_http.Session, server_url: str, language: str, sdk_version: str, gen_version: str) -> None:
-        self._client = client
-        self._security_client = security_client
-        self._server_url = server_url
-        self._language = language
-        self._sdk_version = sdk_version
-        self._gen_version = gen_version
+    def __init__(self, sdk_config: SDKConfiguration) -> None:
+        self.sdk_configuration = sdk_config
 
 
     def cancel_job(self, request: operations.CancelJobRequest) -> operations.CancelJobResponse:
         r"""Cancel a running Job"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
         url = utils.generate_url(operations.CancelJobRequest, base_url, '/jobs/{jobId}', request)
         headers = {}
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('DELETE', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -50,19 +40,19 @@ def cancel_job(self, request: operations.CancelJobRequest) -> operations.CancelJ
 
     def create_job(self, request: shared.JobCreateRequest) -> operations.CreateJobResponse:
         r"""Trigger a sync or reset job of a connection"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
-        url = base_url.removesuffix('/') + '/jobs'
+        url = base_url + '/jobs'
         headers = {}
         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
         if data is None and form is None:
             raise Exception('request body is required')
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('POST', url, data=data, files=form, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -81,14 +71,14 @@ def create_job(self, request: shared.JobCreateRequest) -> operations.CreateJobRe
 
     def get_job(self, request: operations.GetJobRequest) -> operations.GetJobResponse:
         r"""Get Job status and details"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
         url = utils.generate_url(operations.GetJobRequest, base_url, '/jobs/{jobId}', request)
         headers = {}
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('GET', url, headers=headers)
         content_type = http_res.headers.get('Content-Type')
@@ -107,15 +97,15 @@ def get_job(self, request: operations.GetJobRequest) -> operations.GetJobRespons
 
     def list_jobs(self, request: operations.ListJobsRequest) -> operations.ListJobsResponse:
         r"""List Jobs by sync type"""
-        base_url = self._server_url
+        base_url = utils.template_url(*self.sdk_configuration.get_server_details())
 
-        url = base_url.removesuffix('/') + '/jobs'
+        url = base_url + '/jobs'
         headers = {}
         query_params = utils.get_query_params(operations.ListJobsRequest, request)
         headers['Accept'] = 'application/json'
-        headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}'
+        headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}'
 
-        client = self._security_client
+        client = self.sdk_configuration.security_client
 
         http_res = client.request('GET', url, params=query_params, headers=headers)
         content_type = http_res.headers.get('Content-Type')