Sean Han
02/03/2023, 8:20 PMsandy
02/03/2023, 10:57 PMfrom dagster import asset, StaticPartitionsDefinition
@asset
def asset1():
...
@asset(partitions_def=StaticPartitionsDefinition(["a", "b"]))
def asset2(asset1):
...
and it worked OKSean Han
02/03/2023, 11:02 PM@asset
def asset1():
...
@asset(partition_def=DailyPartitionsDefinition(start_date="2022-01-01"))
def asset2(asset1):
...
It is giving me Error occurred while loading input "asset1" of step "asset2"
and The input does not correspond to a partitioned asset
errorsandy
02/03/2023, 11:22 PMSean Han
02/03/2023, 11:26 PM