From fc75690d47be9dd8b0aa94e7bfca9299dad7f012 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 e9dd59df72a08..6ec196e96b4e4 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 @@ -2,7 +2,7 @@ from typing import AbstractSet, Any, Callable, Optional, Union, overload # noqa: UP035 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 @@ -64,7 +64,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, *, @@ -225,7 +224,6 @@ def __call__(self, observe_fn: SourceAssetObserveFunction) -> SourceAsset: ) -@experimental def multi_observable_source_asset( *, specs: Sequence[AssetSpec],