الجدولة والاعتماديات وإعادة المحاولة

required = {'extract', 'transform', 'validate'}
state = {'extract': 'accepted', 'transform': 'accepted', 'validate': 'failed'}
assert not all(state.get(task) == 'accepted' for task in required)
state['validate'] = 'accepted'
assert all(state.get(task) == 'accepted' for task in required)

يحجب الفشل النشر ولا يثبت تغيير الوسم نتيجة فعلية.

def retry_decision(error_kind, attempt, max_attempts=3):
    if error_kind != 'transient':
        return 'fail'
    return 'retry' if attempt < max_attempts else 'fail'

assert retry_decision('transient', 1) == 'retry'
assert retry_decision('transient', 3) == 'fail'
assert retry_decision('schema', 1) == 'fail'

تقيم الوسوم والعداد فقط دون إعادة أو انتظار أو منصة.