Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
495 changes: 284 additions & 211 deletions .speakeasy/gen.lock

Large diffs are not rendered by default.

32 changes: 32 additions & 0 deletions .speakeasy/workflow.lock
Original file line number Diff line number Diff line change
@@ -0,0 +1,32 @@
speakeasyVersion: 1.286.3
sources:
my-source:
sourceNamespace: my-source
sourceRevisionDigest: sha256:0e36eb3e666e71738d7f18746aaf7a4c2242126e2eb8534be3e0d739bab17fe9
sourceBlobDigest: sha256:128e131dbcb3ee37a7b330c750e9687d13058634b6c42c80d71ea6c51e6c4596
tags:
- latest
- main
targets:
python-api:
source: my-source
sourceNamespace: my-source
sourceRevisionDigest: sha256:0e36eb3e666e71738d7f18746aaf7a4c2242126e2eb8534be3e0d739bab17fe9
sourceBlobDigest: sha256:128e131dbcb3ee37a7b330c750e9687d13058634b6c42c80d71ea6c51e6c4596
outLocation: /github/workspace/repo
workflow:
workflowVersion: 1.0.0
speakeasyVersion: latest
sources:
my-source:
inputs:
- location: ./airbyte-api.openapi.yaml
registry:
location: registry.speakeasyapi.dev/airbyte/airbyte-prod/my-source
targets:
python-api:
target: python
source: my-source
publish:
pypi:
token: $PYPI_TOKEN
3 changes: 3 additions & 0 deletions .speakeasy/workflow.yaml
Original file line number Diff line number Diff line change
@@ -1,8 +1,11 @@
workflowVersion: 1.0.0
speakeasyVersion: latest
sources:
my-source:
inputs:
- location: ./airbyte-api.openapi.yaml
registry:
location: registry.speakeasyapi.dev/airbyte/airbyte-prod/my-source
targets:
python-api:
target: python
Expand Down
145 changes: 110 additions & 35 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -39,13 +39,12 @@ s = airbyte_api.AirbyteAPI(
),
)

req = models.ConnectionCreateRequest(
destination_id='c669dd1e-3620-483e-afc8-55914e0a570f',
source_id='6dd427d8-3a55-4584-b835-842325b6c7b3',
res = s.public_connections.create_connection(request=models.ConnectionCreateRequest(
destination_id='e478de0d-a3a0-475c-b019-25f7dd29e281',
source_id='95e66a59-8045-4307-9678-63bc3c9b8c93',
name='Postgres-to-Bigquery',
namespace_format='${SOURCE_NAMESPACE}',
)

res = s.connections.create_connection(req)
))

if res.connection_response is not None:
# handle response
Expand All @@ -57,6 +56,46 @@ if res.connection_response is not None:
<!-- Start Available Resources and Operations [operations] -->
## Available Resources and Operations

### [public_connections](docs/sdks/publicconnections/README.md)

* [create_connection](docs/sdks/publicconnections/README.md#create_connection) - Create a connection
* [delete_connection](docs/sdks/publicconnections/README.md#delete_connection) - Delete a Connection
* [get_connection](docs/sdks/publicconnections/README.md#get_connection) - Get Connection details
* [list_connections](docs/sdks/publicconnections/README.md#list_connections) - List connections
* [patch_connection](docs/sdks/publicconnections/README.md#patch_connection) - Update Connection details

### [public](docs/sdks/public/README.md)

* [cancel_job](docs/sdks/public/README.md#cancel_job) - Cancel a running Job
* [create_connection](docs/sdks/public/README.md#create_connection) - Create a connection
* [create_destination](docs/sdks/public/README.md#create_destination) - Create a destination
* [create_job](docs/sdks/public/README.md#create_job) - Trigger a sync or reset job of a connection
* [create_or_update_workspace_o_auth_credentials](docs/sdks/public/README.md#create_or_update_workspace_o_auth_credentials) - Create OAuth override credentials for a workspace and source type.
* [create_source](docs/sdks/public/README.md#create_source) - Create a source
* [create_workspace](docs/sdks/public/README.md#create_workspace) - Create a workspace
* [delete_connection](docs/sdks/public/README.md#delete_connection) - Delete a Connection
* [delete_destination](docs/sdks/public/README.md#delete_destination) - Delete a Destination
* [delete_source](docs/sdks/public/README.md#delete_source) - Delete a Source
* [delete_workspace](docs/sdks/public/README.md#delete_workspace) - Delete a Workspace
* [get_connection](docs/sdks/public/README.md#get_connection) - Get Connection details
* [get_destination](docs/sdks/public/README.md#get_destination) - Get Destination details
* [get_job](docs/sdks/public/README.md#get_job) - Get Job status and details
* [get_source](docs/sdks/public/README.md#get_source) - Get Source details
* [get_stream_properties](docs/sdks/public/README.md#get_stream_properties) - Get stream properties
* [get_workspace](docs/sdks/public/README.md#get_workspace) - Get Workspace details
* [initiate_o_auth](docs/sdks/public/README.md#initiate_o_auth) - Initiate OAuth for a source
* [list_connections](docs/sdks/public/README.md#list_connections) - List connections
* [list_destinations](docs/sdks/public/README.md#list_destinations) - List destinations
* [list_jobs](docs/sdks/public/README.md#list_jobs) - List Jobs by sync type
* [list_sources](docs/sdks/public/README.md#list_sources) - List sources
* [list_workspaces](docs/sdks/public/README.md#list_workspaces) - List workspaces
* [patch_connection](docs/sdks/public/README.md#patch_connection) - Update Connection details
* [patch_destination](docs/sdks/public/README.md#patch_destination) - Update a Destination
* [patch_source](docs/sdks/public/README.md#patch_source) - Update a Source
* [put_destination](docs/sdks/public/README.md#put_destination) - Update a Destination and fully overwrite it
* [put_source](docs/sdks/public/README.md#put_source) - Update a Source and fully overwrite it
* [update_workspace](docs/sdks/public/README.md#update_workspace) - Update a workspace

### [connections](docs/sdks/connections/README.md)

* [create_connection](docs/sdks/connections/README.md#create_connection) - Create a connection
Expand All @@ -65,6 +104,15 @@ if res.connection_response is not None:
* [list_connections](docs/sdks/connections/README.md#list_connections) - List connections
* [patch_connection](docs/sdks/connections/README.md#patch_connection) - Update Connection details

### [public_destinations](docs/sdks/publicdestinations/README.md)

* [create_destination](docs/sdks/publicdestinations/README.md#create_destination) - Create a destination
* [delete_destination](docs/sdks/publicdestinations/README.md#delete_destination) - Delete a Destination
* [get_destination](docs/sdks/publicdestinations/README.md#get_destination) - Get Destination details
* [list_destinations](docs/sdks/publicdestinations/README.md#list_destinations) - List destinations
* [patch_destination](docs/sdks/publicdestinations/README.md#patch_destination) - Update a Destination
* [put_destination](docs/sdks/publicdestinations/README.md#put_destination) - Update a Destination and fully overwrite it

### [destinations](docs/sdks/destinations/README.md)

* [create_destination](docs/sdks/destinations/README.md#create_destination) - Create a destination
Expand All @@ -74,13 +122,30 @@ if res.connection_response is not None:
* [patch_destination](docs/sdks/destinations/README.md#patch_destination) - Update a Destination
* [put_destination](docs/sdks/destinations/README.md#put_destination) - Update a Destination and fully overwrite it

### [public_jobs](docs/sdks/publicjobs/README.md)

* [cancel_job](docs/sdks/publicjobs/README.md#cancel_job) - Cancel a running Job
* [create_job](docs/sdks/publicjobs/README.md#create_job) - Trigger a sync or reset job of a connection
* [get_job](docs/sdks/publicjobs/README.md#get_job) - Get Job status and details
* [list_jobs](docs/sdks/publicjobs/README.md#list_jobs) - List Jobs by sync type

### [jobs](docs/sdks/jobs/README.md)

* [cancel_job](docs/sdks/jobs/README.md#cancel_job) - Cancel a running Job
* [create_job](docs/sdks/jobs/README.md#create_job) - Trigger a sync or reset job of a connection
* [get_job](docs/sdks/jobs/README.md#get_job) - Get Job status and details
* [list_jobs](docs/sdks/jobs/README.md#list_jobs) - List Jobs by sync type

### [public_sources](docs/sdks/publicsources/README.md)

* [create_source](docs/sdks/publicsources/README.md#create_source) - Create a source
* [delete_source](docs/sdks/publicsources/README.md#delete_source) - Delete a Source
* [get_source](docs/sdks/publicsources/README.md#get_source) - Get Source details
* [initiate_o_auth](docs/sdks/publicsources/README.md#initiate_o_auth) - Initiate OAuth for a source
* [list_sources](docs/sdks/publicsources/README.md#list_sources) - List sources
* [patch_source](docs/sdks/publicsources/README.md#patch_source) - Update a Source
* [put_source](docs/sdks/publicsources/README.md#put_source) - Update a Source and fully overwrite it

### [sources](docs/sdks/sources/README.md)

* [create_source](docs/sdks/sources/README.md#create_source) - Create a source
Expand All @@ -91,10 +156,23 @@ if res.connection_response is not None:
* [patch_source](docs/sdks/sources/README.md#patch_source) - Update a Source
* [put_source](docs/sdks/sources/README.md#put_source) - Update a Source and fully overwrite it

### [public_streams](docs/sdks/publicstreams/README.md)

* [get_stream_properties](docs/sdks/publicstreams/README.md#get_stream_properties) - Get stream properties

### [streams](docs/sdks/streams/README.md)

* [get_stream_properties](docs/sdks/streams/README.md#get_stream_properties) - Get stream properties

### [public_workspaces](docs/sdks/publicworkspaces/README.md)

* [create_or_update_workspace_o_auth_credentials](docs/sdks/publicworkspaces/README.md#create_or_update_workspace_o_auth_credentials) - Create OAuth override credentials for a workspace and source type.
* [create_workspace](docs/sdks/publicworkspaces/README.md#create_workspace) - Create a workspace
* [delete_workspace](docs/sdks/publicworkspaces/README.md#delete_workspace) - Delete a Workspace
* [get_workspace](docs/sdks/publicworkspaces/README.md#get_workspace) - Get Workspace details
* [list_workspaces](docs/sdks/publicworkspaces/README.md#list_workspaces) - List workspaces
* [update_workspace](docs/sdks/publicworkspaces/README.md#update_workspace) - Update a workspace

### [workspaces](docs/sdks/workspaces/README.md)

* [create_or_update_workspace_o_auth_credentials](docs/sdks/workspaces/README.md#create_or_update_workspace_o_auth_credentials) - Create OAuth override credentials for a workspace and source type.
Expand Down Expand Up @@ -135,15 +213,14 @@ s = airbyte_api.AirbyteAPI(
),
)

req = models.ConnectionCreateRequest(
destination_id='c669dd1e-3620-483e-afc8-55914e0a570f',
source_id='6dd427d8-3a55-4584-b835-842325b6c7b3',
namespace_format='${SOURCE_NAMESPACE}',
)

res = None
try:
res = s.connections.create_connection(req)
res = s.public_connections.create_connection(request=models.ConnectionCreateRequest(
destination_id='e478de0d-a3a0-475c-b019-25f7dd29e281',
source_id='95e66a59-8045-4307-9678-63bc3c9b8c93',
name='Postgres-to-Bigquery',
namespace_format='${SOURCE_NAMESPACE}',
))
except errors.SDKError as e:
# handle exception
raise(e)
Expand Down Expand Up @@ -184,13 +261,12 @@ s = airbyte_api.AirbyteAPI(
),
)

req = models.ConnectionCreateRequest(
destination_id='c669dd1e-3620-483e-afc8-55914e0a570f',
source_id='6dd427d8-3a55-4584-b835-842325b6c7b3',
res = s.public_connections.create_connection(request=models.ConnectionCreateRequest(
destination_id='e478de0d-a3a0-475c-b019-25f7dd29e281',
source_id='95e66a59-8045-4307-9678-63bc3c9b8c93',
name='Postgres-to-Bigquery',
namespace_format='${SOURCE_NAMESPACE}',
)

res = s.connections.create_connection(req)
))

if res.connection_response is not None:
# handle response
Expand All @@ -216,13 +292,12 @@ s = airbyte_api.AirbyteAPI(
),
)

req = models.ConnectionCreateRequest(
destination_id='c669dd1e-3620-483e-afc8-55914e0a570f',
source_id='6dd427d8-3a55-4584-b835-842325b6c7b3',
res = s.public_connections.create_connection(request=models.ConnectionCreateRequest(
destination_id='e478de0d-a3a0-475c-b019-25f7dd29e281',
source_id='95e66a59-8045-4307-9678-63bc3c9b8c93',
name='Postgres-to-Bigquery',
namespace_format='${SOURCE_NAMESPACE}',
)

res = s.connections.create_connection(req)
))

if res.connection_response is not None:
# handle response
Expand Down Expand Up @@ -258,10 +333,11 @@ s = airbyte_api.AirbyteAPI(client=http_client)

This SDK supports the following security schemes globally:

| Name | Type | Scheme |
| ------------- | ------------- | ------------- |
| `basic_auth` | http | HTTP Basic |
| `bearer_auth` | http | HTTP Bearer |
| Name | Type | Scheme |
| -------------------- | -------------------- | -------------------- |
| `basic_auth` | http | HTTP Basic |
| `bearer_auth` | http | HTTP Bearer |
| `client_credentials` | oauth2 | OAuth2 token |

You can set the security parameters through the `security` optional parameter when initializing the SDK client instance. The selected scheme will be used by default to authenticate with the API for all operations that support it. For example:
```python
Expand All @@ -277,13 +353,12 @@ s = airbyte_api.AirbyteAPI(
),
)

req = models.ConnectionCreateRequest(
destination_id='c669dd1e-3620-483e-afc8-55914e0a570f',
source_id='6dd427d8-3a55-4584-b835-842325b6c7b3',
res = s.public_connections.create_connection(request=models.ConnectionCreateRequest(
destination_id='e478de0d-a3a0-475c-b019-25f7dd29e281',
source_id='95e66a59-8045-4307-9678-63bc3c9b8c93',
name='Postgres-to-Bigquery',
namespace_format='${SOURCE_NAMESPACE}',
)

res = s.connections.create_connection(req)
))

if res.connection_response is not None:
# handle response
Expand Down
12 changes: 11 additions & 1 deletion RELEASES.md
Original file line number Diff line number Diff line change
Expand Up @@ -888,4 +888,14 @@ Based on:
### Generated
- [python v0.49.2] .
### Releases
- [PyPI v0.49.2] https://pypi.org/project/airbyte-api/0.49.2 - .
- [PyPI v0.49.2] https://pypi.org/project/airbyte-api/0.49.2 - .

## 2024-05-14 00:14:22
### Changes
Based on:
- OpenAPI Doc
- Speakeasy CLI 1.286.3 (2.329.0) https://github.com/speakeasy-api/speakeasy
### Generated
- [python v0.49.3] .
### Releases
- [PyPI v0.49.3] https://pypi.org/project/airbyte-api/0.49.3 - .
11 changes: 5 additions & 6 deletions USAGE.md
Original file line number Diff line number Diff line change
Expand Up @@ -12,13 +12,12 @@ s = airbyte_api.AirbyteAPI(
),
)

req = models.ConnectionCreateRequest(
destination_id='c669dd1e-3620-483e-afc8-55914e0a570f',
source_id='6dd427d8-3a55-4584-b835-842325b6c7b3',
res = s.public_connections.create_connection(request=models.ConnectionCreateRequest(
destination_id='e478de0d-a3a0-475c-b019-25f7dd29e281',
source_id='95e66a59-8045-4307-9678-63bc3c9b8c93',
name='Postgres-to-Bigquery',
namespace_format='${SOURCE_NAMESPACE}',
)

res = s.connections.create_connection(req)
))

if res.connection_response is not None:
# handle response
Expand Down
2 changes: 1 addition & 1 deletion docs/api/getstreampropertiesrequest.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,6 @@

| Field | Type | Required | Description |
| ------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------ | ------------------------------------------------------------------------------------ |
| `destination_id` | *str* | :heavy_check_mark: | ID of the destination |
| `source_id` | *str* | :heavy_check_mark: | ID of the source |
| `destination_id` | *Optional[str]* | :heavy_minus_sign: | ID of the destination |
| `ignore_cache` | *Optional[bool]* | :heavy_minus_sign: | If true pull the latest schema from the source, else pull from cache (default false) |
2 changes: 1 addition & 1 deletion docs/api/getstreampropertiesresponse.md
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,4 @@
| `content_type` | *str* | :heavy_check_mark: | HTTP response content type for this operation |
| `status_code` | *int* | :heavy_check_mark: | HTTP response status code for this operation |
| `raw_response` | [requests.Response](https://requests.readthedocs.io/en/latest/api/#requests.Response) | :heavy_check_mark: | Raw HTTP response; suitable for custom response parsing |
| `stream_properties_response` | [Optional[models.StreamPropertiesResponse]](../models/streampropertiesresponse.md) | :heavy_minus_sign: | Get the available streams properties for a source/destination pair. |
| `stream_properties_response` | List[[models.StreamProperties](../models/streamproperties.md)] | :heavy_minus_sign: | Get the available streams properties for a source/destination pair. |
Loading