शुरू करेंमुफ़्त में शुरू करें

Trigger Rule लागू करना

एक workflow बनाने के बाद, आपको महसूस होता है कि यदि कम से कम एक task फेल हो, तो कुछ अपडेट भेजना Dag के लिए फायदेमंद होगा। आप तय करते हैं कि अपने Dag पर one failed चेक लागू करने वाला एक task जोड़ें ताकि Dag में कोई भी task फेल होने पर आपको alert मिल जाए।

बाकी सभी tasks पहले से परिभाषित हैं और task व dag ऑब्जेक्ट्स आपके लिए पहले से इम्पोर्ट किए गए हैं.

यह अभ्यास पाठ्यक्रम का हिस्सा है

Python में Apache Airflow परिचय

पाठ्यक्रम देखें

अभ्यास निर्देश

  • Trigger rules उपयोग करने के लिए उपयुक्त लाइब्रेरी इम्पोर्ट करें.
  • notify_on_failure task में उपयुक्त trigger rule एट्रिब्यूट जोड़ें.
  • एट्रिब्यूट ऐसा सेट करें कि जब एक या अधिक upstream tasks फेल हों तो यह task ट्रिगर हो.
  • दोनों transform tasks के लिए notify_on_failure को downstream dependency के रूप में सेट करें.

इंटरैक्टिव व्यावहारिक अभ्यास

इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।

# Import TriggerRule
from airflow.utils.____ import ____

@dag(schedule="@daily", start_date=datetime(2026, 5, 1))
def etl_pipeline():

    # Trigger notify_on_failure when any upstream task fails
    @task(____=TriggerRule.____)
    def notify_on_failure(**context) -> None:
        dag_id = context["dag"].dag_id
        run_id = context["run_id"]
        print(f"ALERT: A task failed in DAG '{dag_id}', run '{run_id}'. Sending notification...")

    # Set notify_on_failure downstream of both transform tasks
    [transform_users(), transform_orders()] ____ notify_on_failure()
    
etl_pipeline()
कोड संपादित करें और चलाएँ