Agendando um Dag consumidor em um Asset

Agora que o produtor de vendas sinaliza quando os dados estão prontos, você precisa de um Dag consumidor que rode automaticamente sempre que o asset for atualizado. Defina o mesmo asset (s3://data-lake/sales/daily.csv) e defina a agenda do consumidor para ele, para que o Airflow dispare o Dag após cada atualização.