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 Gemini Enterprise Agent Platform 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 Agent Platform 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 pipeline, ini akan muncul di konsol Cloud de Confiance .
COMPILED_PIPELINE_PATH: Jalur ke file YAML pipeline yang telah dikompilasi. Ini dapat berupa jalur lokal atau Cloud de Confiance by S3NS URI Storage.
PIPELINE_ROOT: Tentukan Cloud Storage URI yang dapat diakses oleh akun layanan pipeline Anda. Artefak operasi pipeline Anda disimpan dalam root pipeline.
PROJECT_ID: Project Cloud de Confiance by S3NS tempat pipeline ini berjalan.
LOCATION: Region tempat pipeline dijalankan. Untuk mengetahui informasi selengkapnya tentang region tempat Agent Platform Pipelines tersedia, lihat panduan lokasi Gemini Enterprise Agent Platform. Jika Anda tidak menetapkan parameter ini, lokasi default yang ditetapkan di dalam
aiplatform.inityang 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
slowsecara default.