PublishedPipeline Klasa
Reprezentuje potok do przesłania bez kodu w języku Python, który go skonstruował.
Ponadto funkcja PublishedPipeline może służyć do ponownego przesłanie elementu Pipeline z różnymi PipelineParameter wartościami i danymi wejściowymi.
Zainicjuj wartość PublishedPipeline.
:p aram punkt końcowy ADRESU URL punktu końcowego REST do przesyłania przebiegów potoku dla tego potoku. :type endpoint: str :p aram total_run_steps: liczba kroków w tym potoku :type total_run_steps: int :p aram workspace: obszar roboczy opublikowanego potoku. :type workspace: azureml.core.Workspace :p aram continue_on_step_failure: czy kontynuować wykonywanie innych kroków w potokuUruchom
Jeśli krok zakończy się niepowodzeniem, wartość domyślna to false.
- Dziedziczenie
-
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)
Parametry
- continue_on_step_failure
- bool
Czy kontynuować wykonywanie innych kroków w potokuRun, jeśli krok zakończy się niepowodzeniem. Wartością domyślną jest false.
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Opublikowany dostawca potoku.
- kwargs
- dict
Niestandardowe argumenty słów kluczowych zarezerwowane do przyszłego programowania
- _pipeline_provider
- <xref:azureml.pipeline.core._workflow_provider._PublishedPipelineProvider>
Opublikowany dostawca potoku.
- kwargs
- dict
Niestandardowe argumenty słów kluczowych zarezerwowane do przyszłego programowania
Uwagi
Element PublishedPipeline można utworzyć na podstawie elementu Pipeline lub PipelineRun.
Przykład publikowania z potoku jest następujący:
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)
Aby opublikować z elementu PipelineRun, użyj polecenia:
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)
Uwaga: parametr continue_on_step_failure określa, czy wykonanie kroków w potoku będzie kontynuowane w przypadku niepowodzenia jednego kroku. Wartość domyślna to False, co oznacza, że w przypadku niepowodzenia jednego kroku wykonanie potoku zostanie zatrzymane, co spowoduje anulowanie wszystkich uruchomionych kroków.
Prześlij element PublishedPipeline przy użyciu polecenia submit. Po wywołaniu przesyłania tworzony jest obiekt, PipelineRun który z kolei tworzy StepRun obiekty dla każdego kroku w przepływie pracy.
Przykład przesyłania elementu PublishedPipeline jest następujący:
from azureml.pipeline.core import PublishedPipeline
published_pipeline = PublishedPipeline.get(workspace=ws, id="published_pipeline_id")
pipeline_run = experiment.submit(published_pipeline)
Istnieje wiele opcjonalnych ustawień, które można określić podczas przesyłania elementu PublishedPipeline. Są one następujące:
continue_on_step_failure: czy kontynuować wykonywanie innych kroków w potokuUruchom, jeśli krok zakończy się niepowodzeniem, opcjonalnie. Tylko kroki, które nie mają zależności od danych wyjściowych kroku, który zakończył się niepowodzeniem, będą kontynuowane. Jeśli to ustawienie parametru zostanie podane, zastąpi to ustawienie w potoku.
pipeline_parameters: Parametry wykonywania potoku, słownik {name: value}. Zobacz PipelineParameter , aby uzyskać więcej informacji.
parent_run_id: możesz podać identyfikator uruchomienia, aby ustawić nadrzędne uruchomienie tego uruchomienia potoku, które znajduje odzwierciedlenie w runHistory. Przebieg nadrzędny musi należeć do tego samego eksperymentu, co przesyłany potok.
Przykład przesyłania elementu PublishedPipeline przy użyciu tych ustawień jest następujący:
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>")
Wszystkie opublikowane potoki mają punkt końcowy REST. Za pomocą punktu końcowego potoku można wyzwolić uruchomienie potoku z systemów zewnętrznych, takich jak klienci spoza języka Python. Aby uzyskać informacje o sposobie uwierzytelniania podczas wywoływania punktów końcowych REST, zobacz https://aka.ms/pl-restep-auth.
Użycie punktu końcowego umożliwia na przykład "zarządzaną powtarzalność" w scenariuszach oceniania wsadowego i ponownego trenowania. Aby uzyskać więcej informacji, zobacz https://aka.ms/pl-first-pipeline.
Metody
disable |
Ustaw opublikowany potok na "Wyłączone" i niedostępny do uruchomienia. |
enable |
Ustaw opublikowany potok na "Aktywny" i dostępny do uruchomienia. |
get |
Pobierz opublikowany potok. |
get_all |
Pobierz wszystkie opublikowane potoki w bieżącym obszarze roboczym. PRZESTARZAŁE: ta metoda jest przestarzała na rzecz metody PublishedPipeline list . |
get_graph |
Pobierz graf opublikowanegopipeline. |
get_step_names |
Pobierz listę nazw kroków w opublikowanejpipeline. |
list |
Pobierz wszystkie opublikowane potoki w bieżącym obszarze roboczym. |
save |
Zapisz plik YAML potoku. Obecnie tylko potoki składające się z modułówSteps są obsługiwane w przypadku eksportowania YAML. |
submit |
Prześlij opublikowany potok. Jest to równoważne użyciu elementu submit. Zwraca przesłany element PipelineRun. Ten obiekt służy do monitorowania i wyświetlania szczegółów przebiegu. |
disable
Ustaw opublikowany potok na "Wyłączone" i niedostępny do uruchomienia.
disable()
enable
Ustaw opublikowany potok na "Aktywny" i dostępny do uruchomienia.
enable()
get
Pobierz opublikowany potok.
static get(workspace, id, _workflow_provider=None, _service_endpoint=None)
Parametry
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Dostawca przepływu pracy.
Zwraca
Obiekt PublishedPipeline.
Typ zwracany
get_all
Pobierz wszystkie opublikowane potoki w bieżącym obszarze roboczym.
PRZESTARZAŁE: ta metoda jest przestarzała na rzecz metody PublishedPipeline list .
static get_all(workspace, active_only=True, _service_endpoint=None)
Parametry
- active_only
- bool
Czy zwracać tylko opublikowane potoki, które są obecnie aktywne.
Zwraca
Lista obiektów PublishedPipeline.
Typ zwracany
get_graph
Pobierz graf opublikowanegopipeline.
get_graph(_workflow_provider=None)
Parametry
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Dostawca przepływu pracy.
Zwraca
Wykres.
Typ zwracany
get_step_names
Pobierz listę nazw kroków w opublikowanejpipeline.
get_step_names(_workflow_provider=None)
Parametry
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Dostawca przepływu pracy.
Zwraca
Lista nazw kroków w opublikowanympipeline.
Typ zwracany
list
Pobierz wszystkie opublikowane potoki w bieżącym obszarze roboczym.
static list(workspace, active_only=True, _service_endpoint=None)
Parametry
- active_only
- bool
Czy zwracać tylko opublikowane potoki, które są obecnie aktywne.
Zwraca
Lista obiektów PublishedPipeline.
Typ zwracany
save
Zapisz plik YAML potoku.
Obecnie tylko potoki składające się z modułówSteps są obsługiwane w przypadku eksportowania YAML.
save(path=None, _workflow_provider=None)
Parametry
- path
- str
Ścieżka do zapisania kodu YAML. Jeśli ścieżka jest katalogiem, plik YAML potoku jest zapisywany w pliku path/pipeline_name.yml. Jeśli ścieżka to Brak, używany jest bieżący katalog.
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Dostawca przepływu pracy.
Typ zwracany
submit
Prześlij opublikowany potok. Jest to równoważne użyciu elementu submit.
Zwraca przesłany element PipelineRun. Ten obiekt służy do monitorowania i wyświetlania szczegółów przebiegu.
submit(workspace, experiment_name, pipeline_parameters=None, _workflow_provider=None, _service_endpoint=None, parent_run_id=None, continue_on_step_failure=None)
Parametry
- pipeline_parameters
- dict
Słownik parametrów do przypisywania nowych wartości {param name, param value}. Aby uzyskać więcej informacji, zobacz PipelineParameter .
- _workflow_provider
- <xref:azureml.pipeline.core._aeva_provider._AevaWorkflowProvider>
Dostawca przepływu pracy.
- parent_run_id
- str
Opcjonalny identyfikator uruchomienia ustawiony dla nadrzędnego uruchomienia tego uruchomienia potoku, który jest odzwierciedlony w runHistory. Uruchomienie nadrzędne musi należeć do tego samego eksperymentu, do którego jest przesyłany ten potok.
- continue_on_step_failure
- bool
Czy kontynuować wykonywanie innych kroków w potokuRun, jeśli krok zakończy się niepowodzeniem, opcjonalnie. Jeśli zostanie podana, zastąpi ustawienie potoku.
Zwraca
Przesłane uruchomienie potoku.
Typ zwracany
Atrybuty
continue_on_step_failure
Pobierz wartość continue_on_step_failure
ustawienia.
Zwraca
Wartość continue_on_step_failure
ustawienia.
Typ zwracany
description
endpoint
Pobierz adres URL punktu końcowego REST na potrzeby uruchamiania opublikowanego potoku.
Zwraca
Adres URL punktu końcowego REST do uruchamiania opublikowanego potoku.
Typ zwracany
graph_id
Pobierz identyfikator grafu dla tego opublikowanego potoku.
Zwraca
Identyfikator grafu.
Typ zwracany
id
Pobierz opublikowany identyfikator potoku.
Zwraca
Identyfikator opublikowanego potoku.
Typ zwracany
name
status
total_run_steps
version
Opinia
https://aka.ms/ContentUserFeedback.
Dostępne już wkrótce: W 2024 r. będziemy stopniowo wycofywać zgłoszenia z serwisu GitHub jako mechanizm przesyłania opinii na temat zawartości i zastępować go nowym systemem opinii. Aby uzyskać więcej informacji, sprawdź:Prześlij i wyświetl opinię dla