Dag’lerin Zamanlanması

Python ile Apache Airflow’a Giriş

Mike Metzger

Data Engineer

Dag Çalıştırmaları

Belirli bir anda bir iş akışının tekil örneği
Elle veya schedule ile tetiklenebilir
Her iş akışı ve içindeki görevler için durum tutar
- running
- failed
- success

¹ https://airflow.apache.org/docs/stable/scheduler.html

Tüm Dag’lerde son çalıştırmaları listeleyen Airflow Dag Runs sayfası

Her çalıştırmanın durum sütununu gösteren Airflow Dag Runs sayfası

Bir Dag’i zamanlarken dikkat edilmesi gereken öznitelikler:

schedule şunları belirtir:

Beş boşlukla ayrılmış zaman alanını gösteren cron söz dizimi diyagramı

Beş boşlukla ayrılmış zaman alanını gösteren cron söz dizimi diyagramı

0 12 * * *              # Her gün öğlen çalıştır

* * 25 2 *              # 25 Şubat’ta her dakika çalıştır

0,15,30,45 * * * *      # Her 15 dakikada bir çalıştır

Önayarlar:

cron karşılığı:

¹ https://airflow.apache.org/docs/stable/scheduler.html

Airflow’da üç özel schedule önayarı vardır:

from pendulum import duration

@dag(
  dag_id="example_dag"
  schedule=duration(days=2)
)

@dag(
  dag_id="example_dag",
  schedule="0 12 * * *"
)

@dag(
  dag_id="example_dag",
  schedule="@daily"     
)

Bir Dag’i zamanlarken Airflow şunları yapar:

'start_date': datetime(2026, 2, 25, tz="UTC")
'schedule': @daily

Dag’in en erken başlangıcı 26 Şubat 2026’dır

Python ile Apache Airflow’a Giriş