Планування Dag-споживача на Asset

Тепер, коли продюсер продажів сигналізує про готовність даних, вам потрібен Dag-споживач, який автоматично запускається щоразу, коли asset оновлюється. Визначте той самий asset (s3://data-lake/sales/daily.csv) і встановіть для нього розклад споживача, щоб Airflow запускав Dag після кожного оновлення.