הגדרת ניסיונות חוזרים למשימה בצינור עיבוד נתונים

אתם יכולים לציין אם צריך להפעיל מחדש משימה בצינור אם היא נכשלת, על ידי הגדרת הניסיונות החוזרים למשימה הזו. אתם יכולים להגדיר את מספר הניסיונות להפעלה מחדש של המשימה במקרה של כשל, ואת ההשהיה בין הניסיונות החוזרים הבאים.

אפשר להשתמש בדוגמת הקוד הבאה כדי להגדיר את מדיניות הכשל של משימה בצינור עיבוד נתונים בשם train_op באמצעות השיטה set_retry ב-Kubeflow Pipelines SDK:

from kfp import dsl

@dsl.pipeline(name='custom-container-pipeline')
def pipeline():
  generate = generate_op()
  train = (
    train_op(
      training_data=generate.outputs['training_data'],
      test_data=generate.outputs['test_data'],
      config_file=generate.outputs['config_file'])
    .set_retry(
      num_retries=NUMBER_OF_RETRIES,
      backoff_duration='BACKOFF_DURATION',
      backoff_factor=BACKOFF_FACTOR,
      backoff_max_duration='BACKOFF_MAX_DURATION'
    )

מחליפים את מה שכתוב בשדות הבאים:

• ‫NUMBER_OF_RETRIES: מספר הפעמים לניסיון חוזר של המשימה במקרה של כשל.

• ‫BACKOFF_DURATION: אופציונלי. משך ההמתנה אחרי שהמשימה נכשלת לפני שמנסים שוב. אם לא מגדירים את הפרמטר הזה, משך הזמן מוגדר כברירת מחדל ל-0s.

• ‫BACKOFF_FACTOR: אופציונלי. הפקטור שבו מכפילים את משך ההשהיה לפני ניסיון חוזר בכל ניסיון חוזר עוקב. אם לא מגדירים את הפרמטר הזה, גורם ההשהיה מוגדר כ-2.0 כברירת מחדל.

• ‫BACKOFF_MAX_DURATION: אופציונלי. משך ההשהיה לפני ניסיון חוזר המקסימלי בין ניסיונות חוזרים עוקבים. אם לא מגדירים את הפרמטר הזה, משך הזמן המקסימלי מוגדר כברירת מחדל ל-3600s.