The GitHub Actions job "Tests (ARM)" on airflow.git/v3-3-test has failed.
Run started by GitHub user vatsrahul1001 (triggered by vatsrahul1001).

Head commit for run:
95a48f50c170b1340881cc945f579ef21cd755c1 / github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
[v3-3-test] Fix asset event ingestion crash for Dags using FixedKeyMapper 
(#69311) (#69326)

* Fix asset event ingestion crash for Dags using FixedKeyMapper

Core FixedKeyMapper's generated __init__ never called PartitionMapper.__init__, 
so instances had no max_downstream_keys attribute. Since the Execution API 
reads mapper.max_downstream_keys with no surrounding error handling when 
queuing partitioned Dag runs, every producer task emitting an asset event 
consumed by a Dag with a bare FixedKeyMapper failed to record SUCCESS and 
became a zombie.

* fixup! Fix asset event ingestion crash for Dags using FixedKeyMapper
(cherry picked from commit 0643e33e3f287bbf7eadc38f8cf091edc6d99e3c)

Co-authored-by: Wei Lee <[email protected]>

Report URL: https://github.com/apache/airflow/actions/runs/28657889697

With regards,
GitHub Actions via GitBox


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

Reply via email to