Pipeline yürütme sırasını tanımlama
DAG'ini oluşturduktan sonra, DAG'in görevleri için yürütme sırasını tanımlama zamanı.
Önceki egzersizde, ilk görevi API'yi kontrol edecek şekilde kurdun. Pipeline'daki diğer tüm görevler senin için hazırlandı.
Aşağıdaki diyagramdaki görev sırasını izlemen gerekiyor.
Bu egzersiz
Üretim için Tahmin (Forecasting) Hatları Tasarlama
kursunun bir parçasıdırEgzersiz talimatları
- API kontrol pipeline'ını ve durum kontrolü görevlerini ayarla.
- Veri doğrulama pipeline görevlerini ayarla.
- Tahmin pipeline görevlerini ayarla.
Uygulamalı interaktif egzersiz
Bu örnek kodu tamamlayarak bu egzersizi bitirin.
# 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")