Rodrigo Parra
12/21/2022, 2:47 PMcontext.upstream_output.has_partition_key
is False
.
Why could this be happening? Both assets are annotated with @asset(partitions_def=DailyPartitionsDefinition(start_date="2015-02-10"))
and their job definitions include partitions_def=DailyPartitionsDefinition(start_date="2015-02-10")
as a parameter. I need the io manager the pick up only the partition from A that corresponds to the same date of B that I’m trying to materialize.Rodrigo Parra
12/21/2022, 3:11 PMRodrigo Parra
12/22/2022, 8:56 PM