Skip to content

Commit 4367d44

Browse files
authored
[core-api][experimental] allow_nonexistent_upstream_partitions (#26708)
## Summary & Motivation decision: experimental -> beta reason: this is a fairly niche option, and we might want to change the name in the future docs exist: n/a ## How I Tested These Changes ## Changelog > Insert changelog entry or delete this section.
1 parent 46636b1 commit 4367d44

File tree

3 files changed

+4
-9
lines changed

3 files changed

+4
-9
lines changed

python_modules/dagster/dagster/_core/definitions/metadata/metadata_value.py

+1-3
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88

99
import dagster._check as check
1010
import dagster._seven as seven
11-
from dagster._annotations import PublicAttr, experimental, public
11+
from dagster._annotations import PublicAttr, public
1212
from dagster._core.definitions.asset_key import AssetKey
1313
from dagster._core.definitions.metadata.table import (
1414
TableColumn as TableColumn,
@@ -402,7 +402,6 @@ def emit_metadata(context, df):
402402

403403
@public
404404
@staticmethod
405-
@experimental
406405
def table(
407406
records: Sequence[TableRecord], schema: Optional[TableSchema] = None
408407
) -> "TableMetadataValue":
@@ -883,7 +882,6 @@ def value(self) -> AssetKey:
883882

884883

885884
# This should be deprecated or fixed so that `value` does not return itself.
886-
@experimental
887885
@whitelist_for_serdes(storage_name="TableMetadataEntryData")
888886
class TableMetadataValue(
889887
NamedTuple(

python_modules/dagster/dagster/_core/definitions/metadata/table.py

+1-4
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
from typing import NamedTuple, Optional, Union
33

44
import dagster._check as check
5-
from dagster._annotations import PublicAttr, experimental, public
5+
from dagster._annotations import PublicAttr, public
66
from dagster._core.definitions.asset_key import AssetKey, CoercibleToAssetKey
77
from dagster._serdes.serdes import whitelist_for_serdes
88

@@ -11,7 +11,6 @@
1111
# ########################
1212

1313

14-
@experimental
1514
@whitelist_for_serdes
1615
class TableRecord(
1716
NamedTuple(
@@ -268,7 +267,6 @@ def from_name_type_dict(name_type_dict: Mapping[str, str]):
268267
# ###########################
269268

270269

271-
@experimental(emit_runtime_warning=False)
272270
@whitelist_for_serdes
273271
class TableColumnDep(
274272
NamedTuple(
@@ -293,7 +291,6 @@ def __new__(
293291
)
294292

295293

296-
@experimental
297294
@whitelist_for_serdes
298295
class TableColumnLineage(
299296
NamedTuple(

python_modules/dagster/dagster/_core/definitions/time_window_partition_mapping.py

+2-2
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
from typing import NamedTuple, Optional, cast
44

55
import dagster._check as check
6-
from dagster._annotations import PublicAttr, experimental_param
6+
from dagster._annotations import PublicAttr, beta_param
77
from dagster._core.definitions.partition import (
88
AllPartitionsSubset,
99
PartitionsDefinition,
@@ -22,7 +22,7 @@
2222

2323

2424
@whitelist_for_serdes
25-
@experimental_param(param="allow_nonexistent_upstream_partitions")
25+
@beta_param(param="allow_nonexistent_upstream_partitions")
2626
class TimeWindowPartitionMapping(
2727
PartitionMapping,
2828
NamedTuple(

0 commit comments

Comments
 (0)