定义任务执行顺序
现在您已经了解了位移语法，是时候来定义任务的执行顺序了。您目前有 3 个已定义的任务：cleanup、consolidate 和 push_data。
来自 airflow.sdk 的 dag 与 task 装饰器已导入。
本练习是课程的一部分
Python 中的 Apache Airflow 入门
练习说明
- 使用位移语法，将
cleanup任务配置为先于consolidate任务运行。 - 将
consolidate配置为接着运行，并将push_data任务配置为最后运行。
交互式实操练习
通过完成这段示例代码来试试这个练习。
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()