Configure a política de falhas

Pode usar o parâmetro failure_policy da classe aiplatform.PipelineJob para configurar se um pipeline deve falhar imediatamente se uma das tarefas falhar.

As seguintes configurações de políticas de falhas são suportadas nos Vertex AI Pipelines:

  • Falhar rapidamente (failure_policy = 'fast'): escolha esta configuração se quiser que o pipeline pare de agendar novas tarefas após a falha de uma tarefa. As tarefas já agendadas continuam a ser executadas até serem concluídas.

  • Falha lenta (failure_policy = 'slow'): escolha esta configuração se quiser que o pipeline continue a ser executado mesmo após uma falha de uma tarefa. O pipeline continua a ser executado até que todas as tarefas tenham sido executadas.

Use o seguinte exemplo de código para configurar a política de falhas de um pipeline através do SDK 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')

Substitua o seguinte:

  • DISPLAY_NAME: o nome do pipeline, que é apresentado na Google Cloud consola.

  • COMPILED_PIPELINE_PATH: o caminho para o ficheiro YAML da pipeline compilada. Pode ser um caminho local ou um Google Cloud URI de armazenamento.

  • PIPELINE_ROOT: especifique um URI do Cloud Storage ao qual a conta de serviço das suas pipelines pode aceder. Os artefactos das execuções do pipeline são armazenados na raiz do pipeline.

  • PROJECT_ID: O Google Cloud projeto no qual esta pipeline é executada.

  • LOCATION: a região em que o pipeline é executado. Para mais informações sobre as regiões em que o Vertex AI Pipelines está disponível, consulte o guia de localizações da Vertex AI. Se não definir este parâmetro, é usada a localização predefinida definida em aiplatform.init.

  • FAILURE_POLICY: especifique a política de falhas para todo o pipeline. Estão disponíveis as seguintes configurações:

    • Para configurar o pipeline de modo a falhar após a falha de uma tarefa, introduza fast.

    • Para configurar o pipeline de modo a continuar a agendar tarefas depois de uma tarefa falhar, introduza slow.

    Se não definir este parâmetro, a configuração da política de falhas é definida como slow por predefinição.

O que se segue?