कैसे मैं एक <strong>LocalExecutor</strong> उपयोग कर रहा हूँ वायु प्रवाह

Question

पर एक असफल कार्य पुन: प्रारंभ करने और मेरे डेग 3 कार्य है जहां काम (सी) कार्य (ए) पर निर्भर है। टास्क (बी) और कार्य (ए) की तरह समानांतर कुछ में चला सकते हैं नीचे

A -> सी

बी

तो काम (ए) में नाकाम रही है और लेकिन कार्य (बी) ठीक भाग गया। कार्य (सी) अभी तक कार्य नहीं है क्योंकि कार्य (ए) विफल रहा है।

मेरा प्रश्न मैं कार्य (ए) अकेले कैसे चला सकता हूं इसलिए कार्य (सी) चलाता है जब एक बार कार्य (ए) पूर्ण हो जाता है और एयरफ्लो यूआई उन्हें सफलता के रूप में चिह्नित करता है।

Answer 1

UI में:

1. डेग पर जाएँ, और रन आप GraphView पर
2. क्लिक करें बदलने के लिए काम पर
3. क्लिक करें एक
4. पर क्लिक करें "साफ़"
चाहते हैं डेग रन

यह कार्य को फिर से चलाने देगा, और यदि यह सफल होता है, तो कार्य सी को चलाना चाहिए। यह काम करता है क्योंकि जब आप किसी कार्य की स्थिति को साफ़ करते हैं, तो शेड्यूलर इसका इलाज करेगा जैसे कि यह इस डैग रन के लिए पहले नहीं चला था।