1. Learn
    2. /
  2. คอร์ส
    3. /
  3. Python में Apache Airflow परिचय
Connected

แบบฝึกหัด

Trigger Rule लागू करना

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

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

คำแนะนำ

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