PublishedPipeline Kelas
Mewakili Alur yang akan dikirimkan tanpa kode Python yang membuatnya.
Selain itu, PublishedPipeline dapat digunakan untuk mengirim ulang Pipeline dengan nilai dan input PipelineParameter yang berbeda.
Menginisialisasi PublishedPipeline.
:p titik akhir URL titik akhir REST untuk mengirimkan eksekusi alur untuk alur ini. :type endpoint: str :p aram total_run_steps: Jumlah langkah dalam alur ini :type total_run_steps: int :p aram workspace: Ruang kerja alur yang diterbitkan. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: Apakah akan melanjutkan eksekusi langkah-langkah lain di PipelineRun
jika langkah gagal, defaultnya adalah false.
- Warisan
-
azureml.core._portal.HasPipelinePortalPublishedPipeline
Konstruktor
PublishedPipeline(name, graph_id, description, version, published_pipeline_id, status, endpoint, total_run_steps, workspace, continue_on_step_failure=None, _pipeline_provider=None, **kwargs)
Parameter
- continue_on_step_failure
- bool
Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika suatu langkah gagal. Defaultnya adalah false (salah).
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Penyedia alur yang diterbitkan.
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Penyedia alur yang diterbitkan.
Keterangan
PublishedPipeline dapat dibuat dari Pipeline atau PipelineRun.
Contoh menerbitkan dari Alur adalah sebagai berikut:
from azureml.pipeline.core import Pipeline
pipeline = Pipeline(workspace=ws, steps=steps)
published_pipeline = pipeline.publish(name="My_New_Pipeline",
description="My New Pipeline Description",
version="1.0",
continue_on_step_failure=True)
Untuk menerbitkan dari PipelineRun, gunakan:
from azureml.pipeline.core import PipelineRun
pipeline_run = PipelineRun(experiment=Experiment(ws, "Pipeline_experiment"), run_id="run_id")
published_pipeline = pipeline_run.publish_pipeline(name="My_New_Pipeline",
description="My New Pipeline Description",
version="1.0",
continue_on_step_failure=True)
Catatan: parameter continue_on_step_failure menentukan apakah eksekusi langkah-langkah dalam Alur akan berlanjut jika satu langkah gagal. Nilai default adalah False, artinya ketika satu langkah gagal, eksekusi Alur akan berhenti, membatalkan langkah-langkah yang sedang berjalan.
Kirimkan PublishedPipeline menggunakan submit. Saat pengiriman dipanggil, PipelineRun dibuat yang pada gilirannya membuat objek StepRun untuk setiap langkah dalam alur kerja.
Contoh mengirimkan PublishedPipeline adalah sebagai berikut:
from azureml.pipeline.core import PublishedPipeline
published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
pipeline_run = experiment.submit(published_pipeline)
Ada sejumlah pengaturan opsional yang dapat ditentukan saat mengirimkan PublishedPipeline. Hal ini termasuk:
continue_on_step_failure: Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah yang dilakukan gagal, opsional. Hanya langkah-langkah yang tidak memiliki dependensi pada output langkah yang gagal yang akan melanjutkan eksekusi. Jika disediakan, pengaturan parameter ini akan mengambil alih pengaturan pada Alur.
pipeline_parameters: Parameter untuk eksekusi alur, kamus {name: value}. Lihat PipelineParameter untuk detail selengkapnya.
parent_run_id: Anda dapat memberikan ID eksekusi untuk mengatur eksekusi induk dari eksekusi alur ini, yang tercermin dalam RunHistory. Eksekusi induk harus termasuk dalam eksperimen yang sama dengan alur yang dikirimkan.
Contoh mengirimkan PublishedPipeline menggunakan pengaturan ini adalah sebagai berikut:
from azureml.pipeline.core import PublishedPipeline
published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
pipeline_run = experiment.submit(published_pipeline,
continue_on_step_failure=True,
pipeline_parameters={"param1": "value1"},
parent_run_id="<run_id>")
Semua alur yang diterbitkan memiliki titik akhir REST. Dengan titik akhir alur, Anda dapat memicu eksekusi alur dari sistem eksternal, seperti klien non-Python. Untuk informasi tentang cara mengautentikasi saat memanggil titik akhir REST, lihat https://aka.ms/pl-restep-auth.
Menggunakan titik akhir memungkinkan "pengulangan terkelola" dalam skenario penilaian batch dan pelatihan ulang, misalnya. Untuk informasi selengkapnya, lihat https://aka.ms/pl-first-pipeline.
Metode
disable |
Atur alur yang diterbitkan ke 'Dinonaktifkan' dan tidak tersedia untuk dijalankan. |
enable |
Atur alur yang diterbitkan ke 'Aktif' dan tersedia untuk dijalankan. |
get |
Dapatkan alur yang diterbitkan. |
get_all |
Dapatkan semua alur yang diterbitkan di ruang kerja saat ini. TIDAK DIGUNAKAN LAGI: Metode ini tidak digunakan lagi karena metode PublishedPipeline list. |
get_graph |
Dapatkan grafik PublishedPipeline. |
get_step_names |
Dapatkan daftar nama langkah-langkah di PublishedPipeline. |
list |
Dapatkan semua alur yang diterbitkan di ruang kerja saat ini. |
save |
Simpan YAML Alur ke file. Saat ini, hanya alur yang terdiri dari ModuleSteps yang didukung untuk ekspor YAML. |
submit |
Kirim alur yang diterbitkan. Tindakan ini sama dengan menggunakan submit. Mengembalikan PipelineRun yang diserahkan. Gunakan objek ini untuk memantau dan melihat detail eksekusi. |
disable
Atur alur yang diterbitkan ke 'Dinonaktifkan' dan tidak tersedia untuk dijalankan.
disable()
enable
Atur alur yang diterbitkan ke 'Aktif' dan tersedia untuk dijalankan.
enable()
get
Dapatkan alur yang diterbitkan.
static get(workspace, id, _workflow_provider=None, _service_endpoint=None)
Parameter
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Penyedia alur kerja.
Mengembalikan
Objek PublishedPipeline.
Tipe hasil
get_all
Dapatkan semua alur yang diterbitkan di ruang kerja saat ini.
TIDAK DIGUNAKAN LAGI: Metode ini tidak digunakan lagi karena metode PublishedPipeline list.
static get_all(workspace, active_only=True, _service_endpoint=None)
Parameter
- active_only
- bool
Apakah akan menampilkan hanya alur yang diterbitkan yang saat ini aktif saja.
Mengembalikan
Daftar objek PublishedPipeline.
Tipe hasil
get_graph
Dapatkan grafik PublishedPipeline.
get_graph(_workflow_provider=None)
Parameter
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Penyedia alur kerja.
Mengembalikan
Grafiknya.
Tipe hasil
get_step_names
Dapatkan daftar nama langkah-langkah di PublishedPipeline.
get_step_names(_workflow_provider=None)
Parameter
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Penyedia alur kerja.
Mengembalikan
Daftar nama langkah-langkah dalam PublishedPipeline.
Tipe hasil
list
Dapatkan semua alur yang diterbitkan di ruang kerja saat ini.
static list(workspace, active_only=True, _service_endpoint=None)
Parameter
- active_only
- bool
Apakah akan menampilkan hanya alur yang diterbitkan yang saat ini aktif saja.
Mengembalikan
Daftar objek PublishedPipeline.
Tipe hasil
save
Simpan YAML Alur ke file.
Saat ini, hanya alur yang terdiri dari ModuleSteps yang didukung untuk ekspor YAML.
save(path=None, _workflow_provider=None)
Parameter
- path
- str
Jalur untuk menyimpan YAML. Jika jalurnya adalah direktori, file YAML Alur disimpan di path/pipeline_name.yml. Jika jalur Tidak Ada, direktori saat ini akan digunakan.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Penyedia alur kerja.
Tipe hasil
submit
Kirim alur yang diterbitkan. Tindakan ini sama dengan menggunakan submit.
Mengembalikan PipelineRun yang diserahkan. Gunakan objek ini untuk memantau dan melihat detail eksekusi.
submit(workspace, experiment_name, pipeline_parameters=None, _workflow_provider=None, _service_endpoint=None, parent_run_id=None, continue_on_step_failure=None)
Parameter
- pipeline_parameters
- dict
Kamus parameter untuk menetapkan nilai baru {param name, param value}. Lihat PipelineParameter untuk detail selengkapnya.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Penyedia alur kerja.
- parent_run_id
- str
ID eksekusi opsional untuk mengatur eksekusi induk dalam eksekusi alur ini, yang tercermin dalam RunHistory. Eksekusi induk harus termasuk dalam eksperimen yang sama dengan alur ini yang sedang dikirimkan.
- continue_on_step_failure
- bool
Apakah akan melanjutkan eksekusi langkah lain di PipelineRun jika langkah yang dilakukan gagal, opsional. Jika disediakan, eksekusi akan mengambil alih pengaturan pada Alur.
Mengembalikan
Alur yang dikirimkan berjalan.
Tipe hasil
Atribut
continue_on_step_failure
Dapatkan nilai pengaturan continue_on_step_failure
.
Mengembalikan
Nilai pengaturan continue_on_step_failure
.
Tipe hasil
description
Dapatkan deskripsi alur yang diterbitkan.
Mengembalikan
Deskripsi alur yang diterbitkan.
Tipe hasil
endpoint
Dapatkan URL titik akhir REST untuk menjalankan alur yang diterbitkan.
Mengembalikan
URL titik akhir REST untuk menjalankan alur yang diterbitkan.
Tipe hasil
graph_id
id
name
status
total_run_steps
version
Saran dan Komentar
https://aka.ms/ContentUserFeedback.
Segera hadir: Sepanjang tahun 2024 kami akan menghentikan penggunaan GitHub Issues sebagai mekanisme umpan balik untuk konten dan menggantinya dengan sistem umpan balik baru. Untuk mengetahui informasi selengkapnya, lihat:Kirim dan lihat umpan balik untuk