Defining pipeline execution order
After building your DAG, it's time to define the order of execution for the DAG's tasks.
In the previous exercise, you set up the first task to check the API. All the other tasks from the pipeline are set up for you.
You need to follow the order of tasks from the diagram below.
이 연습은 강의의 일부입니다
Designing Forecasting Pipelines for Production
연습 안내
- Set the API check pipeline and check status tasks.
- Set the data validation pipeline tasks.
- Set the forecast pipeline tasks.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Set the API check pipeline tasks
____ >> ____ >> [data_refresh, no_updates]
data_refresh >> [data_validation, data_failure]
# Set the data validation pipeline tasks
data_validation >> check_validation >> [____, ____]
# Set the forecast pipeline tasks
data_valid >> ____ >> ____
print(f"DAG '{dag.dag_id}' ready with {len(dag.tasks)} tasks")