From 11433a6a7fedf37e037f60a6b5fdc82baad7bde1 Mon Sep 17 00:00:00 2001 From: Owen Kephart Date: Mon, 23 Dec 2024 12:08:42 -0500 Subject: [PATCH] [core-apis][experimental] observable_source_asset, multi_observable_source_asset --- .../_core/definitions/decorators/source_asset_decorator.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/python_modules/dagster/dagster/_core/definitions/decorators/source_asset_decorator.py b/python_modules/dagster/dagster/_core/definitions/decorators/source_asset_decorator.py index 51709ace01c78..03b23e9df503a 100644 --- a/python_modules/dagster/dagster/_core/definitions/decorators/source_asset_decorator.py +++ b/python_modules/dagster/dagster/_core/definitions/decorators/source_asset_decorator.py @@ -1,7 +1,7 @@ from typing import AbstractSet, Any, Callable, Mapping, Optional, Sequence, Set, Union, overload import dagster._check as check -from dagster._annotations import experimental, hidden_param +from dagster._annotations import hidden_param from dagster._core.definitions.asset_check_spec import AssetCheckSpec from dagster._core.definitions.asset_spec import AssetExecutionType, AssetSpec from dagster._core.definitions.assets import AssetsDefinition @@ -63,7 +63,6 @@ def observable_source_asset( breaking_version="1.10.0", additional_warn_text="use freshness checks instead.", ) -@experimental def observable_source_asset( observe_fn: Optional[SourceAssetObserveFunction] = None, *, @@ -224,7 +223,6 @@ def __call__(self, observe_fn: SourceAssetObserveFunction) -> SourceAsset: ) -@experimental def multi_observable_source_asset( *, specs: Sequence[AssetSpec],