Marti Mutso
03/17/2023, 7:25 AMAdam Bloom
03/17/2023, 12:11 PMMarti Mutso
03/17/2023, 12:49 PMfrom dagster import DailyPartitionsDefinition, TimeWindowPartitionMapping, AssetIn, asset
partitions_def = DailyPartitionsDefinition(start_date="2020-01-01")
@asset(partitions_def=partitions_def)
def asset1():
...
@asset(
partitions_def=partitions_def,
ins={
"asset1": AssetIn(
partition_mapping=LastPartitionMapping()
)
}
)
def asset2(asset1):
...