Configurar la política de errores

Puedes usar el parámetro failure_policy de la clase aiplatform.PipelineJob para configurar si una canalización debe fallar inmediatamente si falla una de las tareas.

Vertex AI Pipelines admite las siguientes configuraciones de políticas de errores:

  • Fallo rápido (failure_policy = 'fast'): elige esta configuración si quieres que la canalización deje de programar nuevas tareas después de que falle una tarea. Las tareas que ya están programadas seguirán ejecutándose hasta que se completen.

  • Fallo lento (failure_policy = 'slow'): elige esta configuración si quieres que la canalización siga ejecutándose aunque falle una tarea. La canalización sigue ejecutándose hasta que se han completado todas las tareas.

Usa el siguiente código de ejemplo para configurar la política de errores 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')

Haz los cambios siguientes:

  • DISPLAY_NAME: el nombre del flujo de procesamiento, que se mostrará en la Google Cloud consola.

  • COMPILED_PIPELINE_PATH: la ruta al archivo YAML de la canalización compilada. Puede ser una ruta local o un Google Cloud URI de almacenamiento.

  • 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 tu canalización se almacenan en la raíz de la canalización.

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

  • LOCATION: la región en la que se ejecuta el flujo de procesamiento. Para obtener más información sobre las regiones en las que está disponible Vertex AI Pipelines, consulta la guía de ubicaciones de Vertex AI. Si no lo define, se usará la ubicación predeterminada establecida en aiplatform.init.

  • FAILURE_POLICY: especifica la política de errores de toda la canalización. Están disponibles las siguientes configuraciones:

    • Para configurar la canalización de forma que falle después de que falle una tarea, introduce fast.

    • Para configurar la canalización de forma que siga programando tareas aunque una de ellas falle, introduce slow.

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

Siguientes pasos