devgonvarun opened a new issue, #62874:
URL: https://github.com/apache/airflow/issues/62874
### Apache Airflow version
3.1.7
### If "Other Airflow 3 version" selected, which one?
_No response_
### What happened?
I have a minimal producer dag that produces an asset event and second dag
that uses the same Asset as the schedule. Even though the asset event is
created by the producer dag or directly via the UI, the dependent dag does not
trigger.
### What you think should happen instead?
The dag that uses this Asset as schedule should be triggered on asset
events.
### How to reproduce
Minimal code to create a dag that produces an asset event and a second dag
that uses this asset event as schedule.
```
from airflow.sdk import dag, task, Asset
import pendulum
@task(outlets=[Asset("my_asset")])
def produce():
print("hello from task 1")
@task
def consume():
print("hello from task 2")
@dag(
start_date=pendulum.datetime(2025, 6, 29, tz="Europe/Berlin"),
schedule=None,
)
def asset_producer_dag():
produce()
@dag(
start_date=pendulum.datetime(2025, 6, 29, tz="Europe/Berlin"),
schedule=[Asset("my_asset")],
)
def asset_consumer_dag():
consume()
asset_producer_dag()
asset_consumer_dag()
```
Even when the asset event is created by the asset_producer_dag, the
asset_consumer_dag does not get triggered.
### Operating System
Debian GNU/Linux 12 (bookworm)
### Versions of Apache Airflow Providers
_No response_
### Deployment
Official Apache Airflow Helm Chart
### 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
- [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]
