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:
caf786713d9d94420c912255e1dfe6f28adf1fc6 / 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 producer's partition_date is stamped onto AssetEvent at emission;
the consumer's partition_date is computed alongside its target
partition_key at APDR creation (in assets/manager.py:_queue_partitioned_dags)
and stored on AssetPartitionDagRun. The scheduler copies apdr.partition_date
into the consumer DagRun. 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/26447006135

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to