SCrocky opened a new issue, #56749:
URL: https://github.com/apache/airflow/issues/56749

   ### Apache Airflow version
   
   3.1.0
   
   ### If "Other Airflow 2/3 version" selected, which one?
   
   _No response_
   
   ### What happened?
   
   When triggering a DAG via Asset Events, one of three things can happen:
   
    1. A single Asset Event triggers a DAG Run
    2. Multiple Asset Events trigger a single DAG Run
    3. Asset Events that haven't triggered a DAG Run, but are older than the 
last run are silently ignored
   
   In this example:
   
![Image](https://github.com/user-attachments/assets/6d482aea-48cd-428c-bc07-5a2fabd006f3)
   
   The consumer DAG runs twice.
   It consumes 1 Asset Event on the first run, two on the second, and stops 
running.
   
   However if we look at the Asset Events:
   
![Image](https://github.com/user-attachments/assets/6e41fb11-aa95-4374-b02a-822ed11a6c3b)
   
   We see there are 5 Asset Events, and 3 of them have "triggered" DAG Runs.
   
   This is misleading as it makes the user believe there should be 3 DAG Runs, 
not 2.
   
   ### What you think should happen instead?
   
   I think we should add the following changes in the Asset UI page (and the 
corresponding internal changes):
   
    - `Triggered DAG Runs` should only be used on the most **recent** Asset 
Event that a DAG Run consumes.
    - `Included in DAG Run` mention should be used for all other consumed
   
   As for the ignored Asset Events, I see one of two possible solutions:
   
    1. Either this is a bug, and they should trigger a DAG Run
    2. Or this is a feature and they should have some sort of `silently 
consumed` state & label attached to them.
   
   ### How to reproduce
   
   To reproduce simply upload the following DAGs in a brand new Airflow 
instance:
   
   
[check_dataset_sync.py](https://github.com/user-attachments/files/22961635/check_dataset_sync.py)
   
   make sure to use a DB other than SQlite so you can compare the difference 
between `max_active_runs=1` and `max_active_runs=10`.
   
   Then use the `airflow standalone` command.
   Turn all the DAGs on. And manually trigger the `asset generator` DAG once.
   
   ### Operating System
   
   Ubuntu 24
   
   ### Versions of Apache Airflow Providers
   
   ```
   apache-airflow-providers-common-compat   1.7.3
   apache-airflow-providers-common-io       1.6.2
   apache-airflow-providers-common-sql      1.27.5
   apache-airflow-providers-postgres        6.2.3
   apache-airflow-providers-smtp            2.2.0
   apache-airflow-providers-standard        1.6.0
   ```
   
   ### Deployment
   
   Virtualenv installation
   
   ### Deployment details
   
   _No response_
   
   ### Anything else?
   
   Do not use the default SQLite Database as it cannot show the parallelism 
issues
   
   ### Are you willing to submit PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
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]

Reply via email to