github-actions[bot] opened a new pull request, #69326: URL: https://github.com/apache/airflow/pull/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]> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
