Skip to content

Commit 68bbbd1

Browse files
[dagster-airbyte][docs] Update airbyte API docs with asset decorator, factory and materialization method
1 parent b4ebced commit 68bbbd1

File tree

7 files changed

+8
-1
lines changed

7 files changed

+8
-1
lines changed

docs/content/api/modules.json.gz

5.37 KB
Binary file not shown.

docs/content/api/searchindex.json.gz

100 Bytes
Binary file not shown.

docs/content/api/sections.json.gz

1.15 KB
Binary file not shown.

docs/next/public/objects.inv

22 Bytes
Binary file not shown.

docs/sphinx/sections/api/apidocs/libraries/dagster-airbyte.rst

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,10 @@ Assets (Airbyte API)
1717

1818
.. autofunction:: load_airbyte_cloud_asset_specs
1919

20+
.. autodecorator:: airbyte_assets
21+
22+
.. autofunction:: build_airbyte_assets_definitions
23+
2024

2125
Legacy
2226
======

python_modules/libraries/dagster-airbyte/dagster_airbyte/asset_defs.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1062,6 +1062,7 @@ def build_airbyte_assets_definitions(
10621062
10631063
Examples:
10641064
Sync the tables of a Airbyte connection:
1065+
10651066
.. code-block:: python
10661067
10671068
from dagster_airbyte import AirbyteCloudWorkspace, build_airbyte_assets_definitions
@@ -1083,6 +1084,7 @@ def build_airbyte_assets_definitions(
10831084
)
10841085
10851086
Sync the tables of a Airbyte connection with a custom translator:
1087+
10861088
.. code-block:: python
10871089
10881090
from dagster_airbyte import (

python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
get_dagster_logger,
2222
resource,
2323
)
24-
from dagster._annotations import experimental
24+
from dagster._annotations import experimental, public
2525
from dagster._config.pythonic_config import infer_schema_from_config_class
2626
from dagster._core.definitions.asset_spec import AssetSpec
2727
from dagster._core.definitions.definitions_load_context import StateBackedDefinitionsLoader
@@ -1258,6 +1258,7 @@ def _generate_materialization(
12581258
metadata=stream_asset_spec.metadata,
12591259
)
12601260

1261+
@public
12611262
@experimental
12621263
def sync_and_poll(self, context: AssetExecutionContext):
12631264
"""Executes a sync and poll process to materialize Airbyte Cloud assets.

0 commit comments

Comments
 (0)