This is a dedicated watch page for a single video.
Scenario: You are deploying an Apache Airflow DAG in a Cloud Composer 2 instance. The DAG processes incoming files stored in a Cloud Storage bucket, handling one file at a time. The Cloud Composer instance operates in a subnetwork without Internet access. Instead of running the DAG on a set schedule, you need to execute the DAG reactively whenever a new file is added to the bucket. Question: What should you do to achieve this reactive execution?