The GitHub Actions job "Tests (AMD)" on airflow.git/propagate-partition-date-to-consumers has failed. Run started by GitHub user nathadfield (triggered by nathadfield).
Head commit for run: f4808a408232527293fa73fd41cd32b45b928b62 / Nathan Hadfield <[email protected]> AIP-76: Propagate partition_date to consumers of partitioned assets Consumers of partitioned assets receive partition_key (str) but partition_date (datetime) is None on the consumer DagRun, so templates have to parse the key string. Propagate the datetime form alongside the string so consumers can use the canonical filter idiom `{{ partition_date | ds }}` and friends. The consumer's partition_date is computed alongside its target partition_key at APDR creation (in assets/manager.py:_queue_partitioned_dags), threaded in from the producer DagRun's partition_date via register_asset_change rather than stored on AssetEvent, and persisted on AssetPartitionDagRun. The scheduler copies apdr.partition_date into the consumer DagRun, so the date stays consistent with the mapper that produced the key. IdentityMapper passes the source date through; the StartOf*Mapper family normalizes via to_downstream_normalized; other mappers leave partition_date None and consumers fall back to partition_key. closes: #67239 Report URL: https://github.com/apache/airflow/actions/runs/27270920984 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
