Membatalkan operasi pipeline

Jika tidak lagi memerlukan jadwal atau menjalankan pipeline, Anda dapat membatalkannya. Jika ada beberapa proses pipeline yang akan dibatalkan, Anda dapat membatalkan proses pipeline tersebut secara berkelompok.

Saat Anda memulai pembatalan proses pipeline, status proses pipeline berubah menjadi Membatalkan. Selama status ini, Vertex AI Pipelines membatalkan semua tugas yang tersisa dalam pipeline dan semua layanan dan resource yang dipanggil oleh operasi pipeline. Google Cloud Setelah semua tugas, layanan, dan resource ini dibatalkan, status pipeline akan berubah menjadi Dibatalkan.

Perhatikan bahwa eksekusi pipeline yang dibatalkan tidak akan dihapus. Anda memiliki opsi untuk menghapus eksekusi pipeline setelah membatalkannya.

Membatalkan proses pipeline

Untuk membatalkan eksekusi pipeline, gunakan Google Cloud konsol, REST API, atau Vertex AI SDK untuk Python.

Konsol

Gunakan petunjuk berikut untuk membatalkan proses pipeline yang sedang berlangsung dari Google Cloud konsol:

1. Di bagian Vertex AI, buka tab Runs di halaman Pipelines.

   Buka Runs

2. Di kolom Run, klik nama proses pipeline yang ingin Anda batalkan.
3. Di halaman yang menampilkan detail proses pipeline, klik Hentikan. Opsi ini hanya tersedia jika eksekusi pipeline dalam status Berjalan.

Setelah Anda mengklik Hentikan, status pipeline akan berubah menjadi Membatalkan. Setelah semua tugas pipeline, Google Cloud layanan, dan Google Cloud resource yang dipanggil oleh proses dibatalkan, status akan berubah menjadi Dibatalkan.

REST

Untuk membatalkan proses pipeline yang sedang berlangsung atau terjadwal, kirim permintaan POST menggunakan metode pipelineJobs.cancel.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

• LOCATION: Region tempat proses pipeline berada. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
• PROJECT_ID: Google Cloud Project yang berisi eksekusi pipeline.
• PIPELINE_RUN_ID: ID unik dari eksekusi pipeline yang ingin Anda batalkan. ID proses pipeline ditampilkan di tab Proses pada halaman Pipeline di konsol Google Cloud .

Metode HTTP dan URL:

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID:cancel

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Catatan: Perintah berikut mengasumsikan bahwa Anda telah login ke gcloud CLI menggunakan akun pengguna Anda dengan menjalankan gcloud init atau gcloud auth login , atau dengan menggunakan Cloud Shell, yang secara otomatis membuat Anda login ke gcloud CLI . Anda dapat memeriksa akun yang saat ini aktif dengan menjalankan gcloud auth list.

Jalankan perintah berikut:

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d "" \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID:cancel"

PowerShell

Catatan: Perintah berikut mengasumsikan bahwa Anda telah login ke gcloud CLI menggunakan akun pengguna Anda dengan menjalankan gcloud init atau gcloud auth login . Anda dapat memeriksa akun yang saat ini aktif dengan menjalankan gcloud auth list.

Jalankan perintah berikut:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID:cancel" | Select-Object -Expand Content

Anda akan menerima kode status yang menandakan proses berhasil (2xx), dan sebuah respons kosong.

Python

Gunakan contoh berikut untuk membatalkan proses pipeline yang sedang berjalan atau dijadwalkan dengan menggunakan metode PipelineJob.cancel:

from google.cloud import aiplatform
aiplatform.init(project=PROJECT_ID, location=LOCATION)
pipeline_job = aiplatform.PipelineJob.get(resource_name="PIPELINE_RUN_ID")
pipeline_job.cancel()

Ganti kode berikut:

• PROJECT_ID: Google Cloud Project yang berisi eksekusi pipeline.
• LOCATION: Region tempat proses pipeline berada. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
• PIPELINE_RUN_ID dengan ID unik dari proses pipeline yang ingin Anda batalkan. ID ditampilkan di tab Runs pada halaman Pipelines di konsol Google Cloud .

Membatalkan beberapa operasi pipeline

Untuk membatalkan beberapa proses pipeline secara bersamaan, gunakan REST API, atau Vertex AI SDK untuk Python. Anda dapat membatalkan beberapa proses pipeline yang berada di project dan region yang sama.

REST

Untuk membatalkan beberapa proses pipeline yang sedang berlangsung atau terjadwal secara batch, kirim permintaan POST menggunakan metode pipelineJobs.batchCancel.

Sebelum menggunakan salah satu data permintaan, lakukan penggantian berikut:

• LOCATION: Region tempat proses pipeline berada. Untuk mengetahui informasi selengkapnya tentang region yang menyediakan Vertex AI Pipelines, lihat panduan lokasi Vertex AI.
• PROJECT_ID: Google Cloud Project yang berisi eksekusi pipeline.
• PIPELINE_RUN_ID_1, PIPELINE_RUN_ID_2: ID tugas pipeline yang ingin Anda batalkan. Anda dapat menemukan ID tugas di tab Runs di halaman Pipelines di konsol Google Cloud .

Metode HTTP dan URL:

POST https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs:batchCancel

Isi JSON permintaan:

{
  "names": [
    "projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID_1",
    "projects/PROJECT_ID/locations/LOCATION/pipelineJobs/PIPELINE_RUN_ID_2"
  ]
}

Untuk mengirim permintaan Anda, pilih salah satu opsi berikut:

curl

Catatan: Perintah berikut mengasumsikan bahwa Anda telah login ke gcloud CLI menggunakan akun pengguna Anda dengan menjalankan gcloud init atau gcloud auth login , atau dengan menggunakan Cloud Shell, yang secara otomatis membuat Anda login ke gcloud CLI . Anda dapat memeriksa akun yang saat ini aktif dengan menjalankan gcloud auth list.

Simpan isi permintaan dalam file bernama request.json, dan jalankan perintah berikut:

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d @request.json \
     "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs:batchCancel"

PowerShell

Catatan: Perintah berikut mengasumsikan bahwa Anda telah login ke gcloud CLI menggunakan akun pengguna Anda dengan menjalankan gcloud init atau gcloud auth login . Anda dapat memeriksa akun yang saat ini aktif dengan menjalankan gcloud auth list.

Simpan isi permintaan dalam file bernama request.json, dan jalankan perintah berikut:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/json; charset=utf-8" `
    -InFile request.json `
    -Uri "https://LOCATION-aiplatform.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/pipelineJobs:batchCancel" | Select-Object -Expand Content

Anda akan melihat respons JSON seperti berikut:

{
  "name": "projects/PROJECT_NUMBER/locations/LOCATION/operations/OPERATION_ID",
  "metadata": {
    "@type": "type.googleapis.com/google.cloud.aiplatform.v1.BatchCancelPipelineJobsOperationMetadata",
    "genericMetadata": {
      "createTime": "2025-05-25T16:11:21.011113Z",
      "updateTime": "2025-05-25T16:11:21.011113Z"
    }
  }
}

Python

Gunakan contoh berikut untuk membatalkan beberapa proses pipeline yang sedang berlangsung atau terjadwal dengan menggunakan metode PipelineJob.batch_cancel:

from google.cloud import aiplatform_v1
from google.api_core.client_options import ClientOptions
pipeline_run_ids_to_cancel = [
  "PIPELINE_RUN_ID_1",
  "PIPELINE_RUN_ID_2",
]
client_options = ClientOptions(api_endpoint=f"LOCATION-aiplatform.googleapis.com")
pipeline_job_client = aiplatform_v1.PipelineServiceClient(client_options=client_options)
pipeline_resource_names_to_cancel = []
for run_id in pipeline_run_ids_to_cancel:
  full_resource_name = f"projects/PROJECT_NUMBER/locations/LOCATION/pipelineJobs/{run_id.strip()}"
  pipeline_resource_names_to_cancel.append(full_resource_name)
parent = f"projects/PROJECT_ID/locations/LOCATION"
pipeline_job_client.batch_cancel_pipeline_jobs(parent=parent, names=pipeline_resource_names_to_cancel)

Ganti kode berikut:

• PROJECT_ID: Project ID Anda.
• LOCATION: Region tempat pembuatan eksekusi pipeline.
• PROJECT_NUMBER: Nomor project untuk project Anda. Anda dapat menemukan nomor project ini di konsol Google Cloud .Untuk mengetahui informasi selengkapnya, lihat Menemukan nama, nomor, dan ID project.
• PIPELINE_RUN_ID_1 dan PIPELINE_JOB_ID_2: ID unik dari proses pipeline yang ingin Anda batalkan. ID proses pipeline ditampilkan di tab Runs di halaman Pipelines di konsol Google Cloud .