Hello! Is it possible for partitioned assets to be a part of a DAG of non partitioned assets?

Yessir

Great thanks! Where can I find an example of a non partitioned asset depending on a partitioned one?

Here's an example:

@asset(partitions_def=DailyPartitionsDefinition(starte_date=...))
def partitioned():
    ...

@asset
def non_partitioned(partitioned):
    ...

The value passed as an input to the non-partitioned asset will depend on the IO manager used to store the output. If you're using the default IO manager, it will be a dictionary with a key for every partition in the partitioned asset.

Got it thanks! I’m running into an issue where if I materialize the

partitioned

and

non_partitioned

assets at the same time the

non_partitioned

asset fails because not all of the partitions of the

partitioned

asset have been materialized.