Mengonfigurasi kebijakan kegagalan

Anda dapat menggunakan parameter failure_policy dari class aiplatform.PipelineJob untuk mengonfigurasi apakah pipeline akan langsung digagalkan jika salah satu tugas gagal.

Konfigurasi kebijakan kegagalan berikut ini didukung di Vertex AI Pipelines:

  • Fail fast (failure_policy = 'fast'): Pilih konfigurasi ini jika Anda ingin agar pipeline berhenti menjadwalkan tugas baru setelah tugas gagal. Tugas yang telah dijadwalkan akan terus berjalan hingga selesai.

  • Fail slow (failure_policy = 'slow'): Pilih konfigurasi ini jika Anda ingin agar pipeline terus berjalan meskipun tugas gagal. Pipeline terus berjalan sampai semua tugas selesai dijalankan.

Gunakan contoh kode berikut ini guna mengonfigurasi kebijakan kegagalan untuk pipeline menggunakan Vertex AI SDK untuk 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')

Ganti kode berikut:

  • DISPLAY_NAME: Nama dari pipeline, ini akan muncul di dalam Konsol Google Cloud.

  • COMPILED_PIPELINE_PATH: Jalur ke file YAML pipeline yang telah dikompilasi. Ini dapat berupa jalur lokal, atau URI Google Cloud Storage.

  • PIPELINE_ROOT: Tentukan URI Cloud Storage yang dapat diakses oleh akun layanan pipeline Anda. Artefak operasi pipeline Anda disimpan dalam root pipeline.

  • PROJECT_ID: Project Google Cloud tempat pipeline ini berjalan.

  • LOCATION: Region tempat pipeline dijalankan. Untuk informasi selengkapnya tentang region tempat Vertex AI Pipelines tersedia, lihat panduan lokasi Vertex AI. Jika Anda tidak menetapkan parameter ini, lokasi default yang ditetapkan di dalam aiplatform.init yang akan digunakan.

  • FAILURE_POLICY: Menentukan kebijakan kegagalan untuk seluruh pipeline. Konfigurasi berikut ini tersedia:

    • Untuk mengonfigurasi pipeline agar gagal setelah satu tugas gagal, masukkan fast.

    • Untuk mengonfigurasi pipeline agar dapat terus menjadwalkan tugas setelah satu tugas gagal, masukkan slow.

    Jika Anda tidak menetapkan parameter ini, konfigurasi kebijakan kegagalan akan ditetapkan ke slow secara default.