1. Learn
    2. /
  2. कोर्स
    3. /
  3. Python में Apache Airflow परिचय
Connected

अभ्यास

एक @task.branch परिभाषित करें

Airflow में conditional logic की शक्ति के बारे में जानने के बाद, आप @task.branch डेकोरेटर को आज़माना चाहते हैं. आप अलग कोड पाथ चलाना चाहेंगे अगर current execution date नया साल दर्शाती है (जैसे, 2026 बनाम 2025).

Dag आपके लिए परिभाषित है, साथ ही संबंधित tasks भी. आपका मौजूदा काम @task.branch को इम्प्लीमेंट करना है.

निर्देश

100 XP
  • current और previous execution year की तुलना करने के लिए year_check में उपयुक्त Airflow date template variables को parameters के रूप में जोड़ें.
  • हर date parameter से पहले 4 characters slice करके current_year और previous_year असाइन करें.
  • current_year_task और new_year_task पर dependencies सेट करें.