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.