[core-api][experimental] freshness checks

dagster-io · Dec 23, 2024 · 5633503 · 5633503
1 parent b2a4089
commit 5633503
Show file tree

Hide file tree

Showing 5 changed files with 10 additions and 10 deletions.
diff --git a/...s/dagster/dagster/_core/definitions/asset_check_factories/freshness_checks/last_update.py b/...s/dagster/dagster/_core/definitions/asset_check_factories/freshness_checks/last_update.py
@@ -2,7 +2,7 @@
 from typing import Any, Dict, Iterable, Optional, Sequence, Union, cast
 
 from dagster import _check as check
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.asset_check_factories.utils import (
     DEADLINE_CRON_PARAM_KEY,
     DEFAULT_FRESHNESS_SEVERITY,
@@ -40,7 +40,7 @@
 )
 
 
-@experimental
+@beta
 def build_last_update_freshness_checks(
     *,
     assets: Sequence[Union[CoercibleToAssetKey, AssetsDefinition, SourceAsset]],

diff --git a/...odules/dagster/dagster/_core/definitions/asset_check_factories/freshness_checks/sensor.py b/...odules/dagster/dagster/_core/definitions/asset_check_factories/freshness_checks/sensor.py
@@ -2,7 +2,7 @@
 from typing import Iterator, Optional, Sequence, Tuple, Union, cast
 
 from dagster import _check as check
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.asset_check_factories.utils import (
     FRESH_UNTIL_METADATA_KEY,
     ensure_no_duplicate_asset_checks,
@@ -33,7 +33,7 @@
     """
 
 
-@experimental
+@beta
 def build_sensor_for_freshness_checks(
     *,
     freshness_checks: Sequence[AssetChecksDefinition],

diff --git a/...agster/dagster/_core/definitions/asset_check_factories/freshness_checks/time_partition.py b/...agster/dagster/_core/definitions/asset_check_factories/freshness_checks/time_partition.py
@@ -1,7 +1,7 @@
 from typing import Any, Dict, Iterable, Sequence, Union
 
 from dagster import _check as check
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.asset_check_factories.utils import (
     DEADLINE_CRON_PARAM_KEY,
     DEFAULT_FRESHNESS_SEVERITY,
@@ -37,7 +37,7 @@
 )
 
 
-@experimental
+@beta
 def build_time_partition_freshness_checks(
     *,
     assets: Sequence[Union[SourceAsset, CoercibleToAssetKey, AssetsDefinition]],

diff --git a/...modules/dagster/dagster/_core/definitions/asset_check_factories/metadata_bounds_checks.py b/...modules/dagster/dagster/_core/definitions/asset_check_factories/metadata_bounds_checks.py
@@ -2,7 +2,7 @@
 from typing import Optional, Sequence, Tuple, Union, cast
 
 import dagster._check as check
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.asset_check_factories.utils import (
     assets_to_keys,
     build_multi_asset_check,
@@ -21,7 +21,7 @@
 from dagster._core.instance import DagsterInstance
 
 
-@experimental
+@beta
 def build_metadata_bounds_checks(
     *,
     assets: Sequence[Union[CoercibleToAssetKey, AssetsDefinition, SourceAsset]],

diff --git a/...n_modules/dagster/dagster/_core/definitions/asset_check_factories/schema_change_checks.py b/...n_modules/dagster/dagster/_core/definitions/asset_check_factories/schema_change_checks.py
@@ -2,7 +2,7 @@
 
 from pydantic import BaseModel
 
-from dagster._annotations import experimental
+from dagster._annotations import beta
 from dagster._core.definitions.asset_check_factories.utils import build_multi_asset_check
 from dagster._core.definitions.asset_check_spec import (
     AssetCheckKey,
@@ -17,7 +17,7 @@
 from dagster._core.instance import DagsterInstance
 
 
-@experimental
+@beta
 def build_column_schema_change_checks(
     *,
     assets: Sequence[Union[CoercibleToAssetKey, AssetsDefinition, SourceAsset]],