Nicholas Pezolano
02/10/2023, 4:57 PM@asset(partitions_def=daily_partitions_def)
def data_asset_a(context):
return DataAssetA(context)
@asset(partitions_def=daily_partitions_def)
@def data_asset_b(context):
return DataAssetB(context)
@asset(partitions_def=partitions_def)
def calc_asset(context, data_asset):
dt = context.partition_key
df = CALC(data_obj=data_asset).daily_run(dt)
return df
I would like to run the clac asset with the two different data_assets on two different schedules. Is there an good way to do this without creating two calc assets?sean
02/10/2023, 7:23 PMdata_asset_a
and data_asset_b
are differently structured, then you'll need separate calc_asset
assets. However, it's possible that you could use our new Multidimensionally partitioned assets to model your problem, and collapse data_asset_a
and data_asset_b
into one multidimensionally partitioned data_asset
.