Zach
02/15/2023, 10:45 PMcontext.asset_partition_key_range_for_output
/ context.asset_partition_time_window_for_output
to enable a partitioned asset to operate on a range of partitions? I'm currently using context.partition_time_window
and context.asset_partitions_time_window
and am a bit unsure of how to modify my code to use this featureowen
02/15/2023, 10:50 PMcontext.asset_partitions_time_window
) then your code would already support operation on a range of partitions (you'd just need to modify your code if you were using context.partition_key
, which assumes that there's a single partition key being materialized during any given execution)Zach
02/15/2023, 10:53 PMcontext.asset_partition_time_window_for_output
which I hadn't seen beforedagster._check.CheckError: Invariant failed. Description: Tried to access partition_key for a non-partitioned run
when accessing context.partition_time_window
but we're also only on v0.15.9 so it might just be that this functionality was added after that. really need to figure out our dependency conflicts so we can update.owen
02/15/2023, 11:04 PMZach
02/15/2023, 11:06 PM