diff --git a/docs/content/api/modules.json.gz b/docs/content/api/modules.json.gz index f33820543aeac..e79b2da88487c 100644 Binary files a/docs/content/api/modules.json.gz and b/docs/content/api/modules.json.gz differ diff --git a/docs/content/api/searchindex.json.gz b/docs/content/api/searchindex.json.gz index b6ddb156e9d0c..aacb354ace970 100644 Binary files a/docs/content/api/searchindex.json.gz and b/docs/content/api/searchindex.json.gz differ diff --git a/docs/content/api/sections.json.gz b/docs/content/api/sections.json.gz index 329cb44d70198..4fc9f175197c3 100644 Binary files a/docs/content/api/sections.json.gz and b/docs/content/api/sections.json.gz differ diff --git a/docs/next/public/objects.inv b/docs/next/public/objects.inv index 84a6dd893875e..8ecbfbc885ef2 100644 Binary files a/docs/next/public/objects.inv and b/docs/next/public/objects.inv differ diff --git a/docs/sphinx/sections/api/apidocs/libraries/dagster-airbyte.rst b/docs/sphinx/sections/api/apidocs/libraries/dagster-airbyte.rst index b9a4dc1299f85..911d244fb2c4d 100644 --- a/docs/sphinx/sections/api/apidocs/libraries/dagster-airbyte.rst +++ b/docs/sphinx/sections/api/apidocs/libraries/dagster-airbyte.rst @@ -17,6 +17,10 @@ Assets (Airbyte API) .. autofunction:: load_airbyte_cloud_asset_specs +.. autodecorator:: airbyte_assets + +.. autofunction:: build_airbyte_assets_definitions + Legacy ====== diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/asset_defs.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/asset_defs.py index 6f2e2b9caa80a..60edf7dc425cd 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/asset_defs.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/asset_defs.py @@ -1062,6 +1062,7 @@ def build_airbyte_assets_definitions( Examples: Sync the tables of a Airbyte connection: + .. code-block:: python from dagster_airbyte import AirbyteCloudWorkspace, build_airbyte_assets_definitions @@ -1083,6 +1084,7 @@ def build_airbyte_assets_definitions( ) Sync the tables of a Airbyte connection with a custom translator: + .. code-block:: python from dagster_airbyte import ( diff --git a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py index 3bd3e4e36de6e..210cc1d1b16b3 100644 --- a/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py +++ b/python_modules/libraries/dagster-airbyte/dagster_airbyte/resources.py @@ -21,7 +21,7 @@ get_dagster_logger, resource, ) -from dagster._annotations import experimental +from dagster._annotations import experimental, public from dagster._config.pythonic_config import infer_schema_from_config_class from dagster._core.definitions.asset_spec import AssetSpec from dagster._core.definitions.definitions_load_context import StateBackedDefinitionsLoader @@ -1258,6 +1258,7 @@ def _generate_materialization( metadata=stream_asset_spec.metadata, ) + @public @experimental def sync_and_poll(self, context: AssetExecutionContext): """Executes a sync and poll process to materialize Airbyte Cloud assets.