Incorrect ordering of events in triggering_asset_events #52230
Description
Apache Airflow version
3.0.2
If "Other Airflow 2 version" selected, which one?
No response
What happened?
Sometimes, the ordering of the events in triggering_asset_events is incorrect.
What you think should happen instead?
The asset events should keep the consistent order
How to reproduce
I have two dags:
- One is a producer that produce asset through
AssetAlias - Another one is consumer which is scheduled by assets, paused it for process batch asset events for next run.
Manual triggered the paused consumer while there are 10 untriggered assets, and log the events one by one in the list.
Operating System
Debian GNU/Linux 12 (bookworm)
Versions of Apache Airflow Providers
No response
Deployment
Docker-Compose
Deployment details
No response
Anything else?
No response
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct