Configura la política de fallas

Puedes usar el parámetro failure_policy de la clase aiplatform.PipelineJob para configurar si una canalización debe fallar de inmediato en caso de que una de las tareas falle.

Las siguientes opciones de configuración de políticas de fallas son compatibles con Vertex AI Pipelines:

  • Falla rápida (failure_policy = 'fast'): Elige esta configuración si deseas que la canalización deje de programar tareas nuevas después de que una tarea falla. Las tareas que ya están programadas continúan ejecutándose hasta que se completen.

  • Falla lenta (failure_policy = 'slow'): Elige esta configuración si deseas que la canalización continúe ejecutándose incluso después de que falle una tarea. La canalización continúa ejecutándose hasta que se hayan ejecutado todas las tareas.

Usa la siguiente muestra de código a fin de configurar la política de fallas de una canalización con el SDK de Vertex AI para Python:


job = aiplatform.PipelineJob(display_name = 'DISPLAY_NAME',
                             template_path = 'COMPILED_PIPELINE_PATH',
                             pipeline_root = 'PIPELINE_ROOT',
                             project = 'PROJECT_ID',
                             location = 'LOCATION',
                             failure_policy = 'FAILURE_POLICY')

Reemplaza lo siguiente:

  • DISPLAY_NAME: El nombre de la canalización, aparecerá en la consola de Google Cloud.

  • COMPILED_PIPELINE_PATH: Es la ruta de acceso al archivo YAML de canalización compilado. Puede ser una ruta local o un URI de Google Cloud Storage.

  • PIPELINE_ROOT: Especifica un URI de Cloud Storage al que pueda acceder la cuenta de servicio de tus canalizaciones. Los artefactos de las ejecuciones de tus canalizaciones se almacenan en la raíz de la canalización.

  • PROJECT_ID: Es el proyecto de Google Cloud en el que se ejecuta esta canalización.

  • LOCATION: Es la región en la que se ejecuta la canalización. Para obtener más información sobre las regiones en las que Vertex AI Pipelines está disponible, consulta la guía de ubicaciones de Vertex AI. Si no configuras este parámetro, se usa la ubicación predeterminada establecida en aiplatform.init.

  • FAILURE_POLICY: Especifica la política de fallas para toda la canalización. Las siguientes opciones de configuración están disponibles:

    • Para configurar la canalización a fin de que falle después de que una tarea falle, ingresa fast.

    • Para configurar la canalización a fin de continuar programando tareas después de que falle una, ingresa slow.

    Si no estableces este parámetro, la configuración de política de fallas se establece en slow de forma predeterminada.

¿Qué sigue?