https://dagster.io/ logo
Title
s

Sean Han

02/03/2023, 8:20 PM
Hi Team, I have a partitioned asset that depends on a not partitioned static asset, but Dagster complains about upstream asset is not partitioned, which PartitionMapping should I use to map the downstream partitioned asset to not partitioned upstream asset? Thanks!
s

sandy

02/03/2023, 10:57 PM
hey Sean - what complaint are you running into? I just tried out
from dagster import asset, StaticPartitionsDefinition


@asset
def asset1():
    ...


@asset(partitions_def=StaticPartitionsDefinition(["a", "b"]))
def asset2(asset1):
    ...
and it worked OK
s

Sean Han

02/03/2023, 11:02 PM
Sorry I’m not using static partition, here is my code
@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
error
s

sandy

02/03/2023, 11:22 PM
hmm, that worked fine for me too. what version are you on?
s

Sean Han

02/03/2023, 11:26 PM
I’m on 1.1.13, it might be another case where I need to update version I think