Asset를 기반으로 소비자 DAG 스케줄링하기

판매 데이터 생산자 DAG가 데이터 준비 완료 신호를 보내도록 설정했으니, 이제 Asset이 업데이트될 때마다 자동으로 실행되는 소비자 DAG를 만들어야 합니다. 생산자 DAG와 동일한 Asset(s3://data-lake/sales/daily.csv)을 정의하고, 소비자 DAG의 스케줄을 해당 Asset으로 설정하세요. 그러면 Airflow가 업데이트가 발생할 때마다 DAG를 자동으로 트리거합니다.