I have two assets my_asset_a
which runs every day at 4pm and my_asset_b
which runs every day at 6pm. Since my_asset_b
runs after my_asset_a
i’d like for my_asset_a
to depend on the previous partition key of my_asset_b
e.g. if the partition_key is 2024-07-08 i’d like my_asset_a
to depend on the partition_key of 2024-07-07 for my_asset_b
. The reason for this is I’d like flexibility to use my_asset_b
as a dependency on both T and T-1
@asset(partitions_def=daily_partitions_def)
def my_asset_a(context, my_asset_b):
dt = context.partition_key
return run_a(dt, my_asset_b)
@asset(partitions_def=daily_partitions_def)
def my_asset_b(context):
dt = context.partition_key
return run_b(dt)