使用 Asset 输出标记数据可用性

您的团队有一条流水线，会将每日销售数据写入 s3://data-lake/sales/daily.csv，并且有多条下游流水线依赖它。与其让它们按定时轮询或猜测文件何时就绪，不如为此任务附加一个 Asset 输出，这样任务一完成就能发出数据已更新的信号。正是这个信号，让其他 Dag 能够基于数据本身来调度。

完成代码后，运行该文件，然后使用 Airflow CLI 验证该资产已注册并已更新。