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, kursun bir parçasıdır
Üretim için Tahmin (Forecasting) Hatları Tasarlama
Egzersiz talimatları
- API kontrol pipeline'ını ve durum kontrolü görevlerini ayarla.
- Veri doğrulama pipeline görevlerini ayarla.
- Tahmin pipeline görevlerini ayarla.
Uygulamalı etkileşimli egzersiz
Bu egzersizi bu örnek kodu tamamlayarak deneyin.
# 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")