You can achieve this in Apache Airflow by using Asset Aware Scheduling.

Once you have a DAG that uses an asset for scheduling, you can trigger it via the Airflow API Asset event endpoint.

However for this to work, your events must be able to reach the Airflow API. How are you pushing your events?