Bagikan melalui

PublishedPipeline Kelas

  • Referensi

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.HasPipelinePortal
PublishedPipeline

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

name
str
Diperlukan

Nama alur yang diterbitkan.

graph_id
str
Diperlukan

ID grafik untuk alur yang diterbitkan ini.

description
str
Diperlukan

Deskripsi alur yang diterbitkan.

version
str
Diperlukan

Versi alur yang diterbitkan.

published_pipeline_id
str
Diperlukan

ID dari alur yang diterbitkan.

status
str
Diperlukan

Status alur yang diterbitkan ('Aktif' atau 'Dinonaktifkan').

endpoint
str
Diperlukan

URL titik akhir REST guna mengirimkan proses untuk alur ini.

total_run_steps
int
Diperlukan

Jumlah langkah dalam alur ini.

workspace
Workspace
Diperlukan

Ruang kerja alur yang diterbitkan.

continue_on_step_failure
bool
Diperlukan

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>
Diperlukan

Penyedia alur yang diterbitkan.

kwargs
dict
Diperlukan

Argumen kata kunci kustom, dicadangkan untuk pengembangan di masa mendatang

name
str
Diperlukan

Nama alur yang diterbitkan.

graph_id
str
Diperlukan

ID grafik untuk alur yang diterbitkan ini.

description
str
Diperlukan

Deskripsi alur yang diterbitkan.

version
str
Diperlukan

Versi alur yang diterbitkan.

published_pipeline_id
str
Diperlukan

ID dari alur yang diterbitkan.

status
str
Diperlukan

Status alur yang diterbitkan ('Aktif' atau 'Dinonaktifkan').

_pipeline_provider
<xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Diperlukan

Penyedia alur yang diterbitkan.

kwargs
dict
Diperlukan

Argumen kata kunci kustom, dicadangkan untuk pengembangan di masa mendatang

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

workspace
Workspace
Diperlukan

Ruang kerja tempat alur yang diterbitkan dibuat.

id
str
Diperlukan

ID dari alur yang diterbitkan.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
nilai default: None

Penyedia alur kerja.

_service_endpoint
str
nilai default: None

Titik akhir layanan.

Mengembalikan

Objek PublishedPipeline.

Tipe hasil

PublishedPipeline

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

workspace
Workspace
Diperlukan

Ruang kerja tempat alur yang diterbitkan dibuat.

active_only
bool
nilai default: True

Apakah akan menampilkan hanya alur yang diterbitkan yang saat ini aktif saja.

_service_endpoint
str
nilai default: None

Titik akhir layanan.

Mengembalikan

Daftar objek PublishedPipeline.

Tipe hasil

list[PublishedPipeline]

get_graph

Dapatkan grafik PublishedPipeline.

get_graph(_workflow_provider=None)

Parameter

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
nilai default: None

Penyedia alur kerja.

Mengembalikan

Grafiknya.

Tipe hasil

Graph

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>
nilai default: None

Penyedia alur kerja.

Mengembalikan

Daftar nama langkah-langkah dalam PublishedPipeline.

Tipe hasil

List[str]

list

Dapatkan semua alur yang diterbitkan di ruang kerja saat ini.

static list(workspace, active_only=True, _service_endpoint=None)

Parameter

workspace
Workspace
Diperlukan

Ruang kerja tempat alur yang diterbitkan dibuat.

active_only
bool
nilai default: True

Apakah akan menampilkan hanya alur yang diterbitkan yang saat ini aktif saja.

_service_endpoint
str
nilai default: None

Titik akhir layanan.

Mengembalikan

Daftar objek PublishedPipeline.

Tipe hasil

list[PublishedPipeline]

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
nilai default: None

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>
nilai default: None

Penyedia alur kerja.

Tipe hasil

None

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

workspace
Workspace
Diperlukan

Ruang kerja untuk mengirimkan alur yang diterbitkan.

experiment_name
str
Diperlukan

Nama eksperimen yang akan dikirim.

pipeline_parameters
dict
nilai default: None

Kamus parameter untuk menetapkan nilai baru {param name, param value}. Lihat PipelineParameter untuk detail selengkapnya.

_workflow_provider
<xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
nilai default: None

Penyedia alur kerja.

_service_endpoint
str
nilai default: None

Titik akhir layanan.

parent_run_id
str
nilai default: None

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
nilai default: None

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

PipelineRun

Atribut

continue_on_step_failure

Dapatkan nilai pengaturan continue_on_step_failure.

Mengembalikan

Nilai pengaturan continue_on_step_failure.

Tipe hasil

bool

description

Dapatkan deskripsi alur yang diterbitkan.

Mengembalikan

Deskripsi alur yang diterbitkan.

Tipe hasil

str

endpoint

Dapatkan URL titik akhir REST untuk menjalankan alur yang diterbitkan.

Mengembalikan

URL titik akhir REST untuk menjalankan alur yang diterbitkan.

Tipe hasil

str

graph_id

Dapatkan ID grafik untuk alur yang diterbitkan ini.

Mengembalikan

ID grafik.

Tipe hasil

str

id

Dapatkan ID alur yang diterbitkan.

Mengembalikan

ID dari alur yang diterbitkan.

Tipe hasil

str

name

Dapatkan nama alur yang diterbitkan.

Mengembalikan

Nama alur yang diterbitkan.

Tipe hasil

str

status

Dapatkan status alur yang diterbitkan.

Mengembalikan

Status alur yang diterbitkan.

Tipe hasil

str

total_run_steps

Dapatkan jumlah langkah dalam alur.

Mengembalikan

Jumlah langkah dalam alur.

Tipe hasil

int

version

Dapatkan versi alur yang diterbitkan.

Mengembalikan

Versi alur yang diterbitkan.

Tipe hasil

str