PipelineRun Třída

Představuje spuštění objektu Pipeline.

Tuto třídu lze použít ke správě, kontrole stavu a načítání podrobností o spuštění po odeslání spuštění kanálu. Slouží get_steps k načtení StepRun objektů vytvořených spuštěním kanálu. Mezi další použití patří načtení objektu Graph přidruženého ke spuštění kanálu, načtení stavu spuštění kanálu a čekání na dokončení spuštění.

Inicializace spuštění kanálu

Konstruktor

PipelineRun(experiment, run_id, _service_endpoint=None, **kwags)

Parametry

Name	Description
experiment Vyžadováno	Experiment Objekt experimentu přidružený ke spuštění kanálu.
run_id Vyžadováno	str ID spuštění kanálu.
_service_endpoint	str Koncový bod, ke kterému se chcete připojit. Default value: None
experiment Vyžadováno	Experiment Objekt experimentu přidružený ke spuštění kanálu.
run_id Vyžadováno	str ID spuštění kanálu.
_service_endpoint Vyžadováno	str Koncový bod, ke kterému se chcete připojit.

Poznámky

Objekt PipelineRun se vrátí při odesílání Pipeline přes submit. Experimentmetoda . Další informace o tom, jak vytvořit a odeslat kanál naleznete v tématu: https://aka.ms/pl-first-pipeline.

Spuštění kanálu lze také vytvořit instanci spuštění Experiment , do které bylo odesláno, a ID spuštění kanálu následujícím způsobem:


   from azureml.core import Experiment
   from azureml.pipeline.core import PipelineRun

   experiment = Experiment(workspace, "<experiment_name>")
   pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")

Při práci s nástrojem PipelineRun použijte:

wait_for_completion monitorování stavu spuštění a volitelně streamování protokolů spuštění.
get_status pro načtení stavu spuštění.
cancel pro zrušení probíhajícího spuštění kanálu.
get_steps pro zobrazení seznamu vygenerovaných objektů StepRuns. Spuštění kanálu vygeneruje StepRun pro každý krok v kanálu.

Metody

cancel	Zrušte probíhající spuštění.
child_run	Vytvořte podřízené spuštění pro spuštění kanálu. Tato metoda není implementována pro PipelineRun.
complete	Označte spuštění kanálu jako dokončené. Tato metoda není implementována pro PipelineRun. Tato metoda není podporována pro kanály; Stav dokončení nebo selhání spravuje back-end Azure ML.
fail	Označte spuštění kanálu jako neúspěšné. Tato metoda není implementována pro PipelineRun. Tato metoda není podporována pro kanály; Stav dokončení nebo selhání spravuje back-end Azure ML.
find_step_run	Vyhledejte krok spuštění v kanálu podle názvu.
get	Načtěte spuštění kanálu na základě ID spuštění.
get_graph	Získejte graf spuštění kanálu.
get_pipeline_output	Získejte PortDataReference pro daný výstup kanálu.
get_pipeline_runs	Načtěte spuštění kanálu vygenerovaná z publikovaného kanálu.
get_status	Načtěte nejnovější stav spuštění kanálu ze služby. Mezi vrácené běžné hodnoty patří "Spuštěno", "Dokončeno" a "Selhání".
get_steps	Získejte spuštění kroku pro všechny kroky kanálu, které byly dokončeny nebo spuštěny.
get_tags	Získejte sadu značek pro spuštění.
publish_pipeline	Publikujte kanál a zpřístupnit ho pro opětovné spuštění. Koncový bod kanálu můžete získat z objektu PublishedPipeline vráceného touto funkcí. Pomocí koncového bodu kanálu můžete kanál vyvolat z externích aplikací pomocí volání REST. Informace o ověřování při volání koncovýchbodůch https://aka.ms/pl-restep-auth Původní kanál přidružený ke spuštění kanálu se použije jako základ publikovaného kanálu.
save	Uložte kanál YAML do souboru.
wait_for_completion	Počkejte na dokončení tohoto spuštění kanálu. Vrátí stav po čekání.

cancel

Zrušte probíhající spuštění.

cancel()

child_run

Vytvořte podřízené spuštění pro spuštění kanálu. Tato metoda není implementována pro PipelineRun.

child_run(name=None, run_id=None, outputs=None)

Parametry

Name	Description
name	str Volitelný název podřízené osoby. Default value: None
run_id	str Volitelné ID spuštění pro podřízenou hodnotu, jinak použije výchozí hodnotu. Default value: None
outputs	str Volitelný výstupní adresář, který se má sledovat pro podřízené. Default value: None

Návraty

Typ	Description
Run	Podřízený běh.

Výjimky

Typ	Description
NotImplementedError

complete

Označte spuštění kanálu jako dokončené. Tato metoda není implementována pro PipelineRun.

Tato metoda není podporována pro kanály; Stav dokončení nebo selhání spravuje back-end Azure ML.

complete()

Výjimky

Typ	Description
NotImplementedError

fail

Označte spuštění kanálu jako neúspěšné. Tato metoda není implementována pro PipelineRun.

Tato metoda není podporována pro kanály; Stav dokončení nebo selhání spravuje back-end Azure ML.

fail()

Výjimky

Typ	Description
NotImplementedError

find_step_run

Vyhledejte krok spuštění v kanálu podle názvu.

find_step_run(name)

Parametry

Name	Description
name Vyžadováno	str Název kroku, který chcete najít.

Návraty

Typ	Description
list	StepRun Seznam objektů se zadaným názvem

get

Načtěte spuštění kanálu na základě ID spuštění.

static get(workspace, run_id, _service_endpoint=None)

Parametry

Name	Description
workspace Vyžadováno	Workspace Pracovní prostor přidružený ke kanálu.
run_id Vyžadováno	str ID spuštění kanálu.
_service_endpoint	str Koncový bod, ke kterému se chcete připojit. Default value: None

Návraty

Typ	Description
PipelineRun	Objekt PipelineRun

get_graph

Získejte graf spuštění kanálu.

get_graph()

Návraty

Typ	Description
Graph	Graf.

get_pipeline_output

Získejte PortDataReference pro daný výstup kanálu.

get_pipeline_output(pipeline_output_name)

Parametry

Name	Description
pipeline_output_name Vyžadováno	str Název výstupu kanálu, který chcete získat.

Návraty

Typ	Description
PortDataReference	PortDataReference představující výstupní data kanálu.

get_pipeline_runs

Načtěte spuštění kanálu vygenerovaná z publikovaného kanálu.

static get_pipeline_runs(workspace, pipeline_id, _service_endpoint=None)

Parametry

Name	Description
workspace Vyžadováno	Workspace Pracovní prostor přidružený ke kanálu.
pipeline_id Vyžadováno	str ID publikovaného kanálu.
_service_endpoint	str Koncový bod, ke kterému se chcete připojit. Default value: None

Návraty

Typ	Description
list	Seznam PipelineRun objektů.

get_status

Načtěte nejnovější stav spuštění kanálu ze služby.

Mezi vrácené běžné hodnoty patří "Spuštěno", "Dokončeno" a "Selhání".

get_status()

Návraty

Typ	Description
str	Nejnovější stav jako řetězec.

Poznámky

NotStarted – Jedná se o dočasné objekty spuštění na straně klienta před odesláním cloudu.
Spuštěno – úloha se začala spouštět v cílovém výpočetním objektu.
Selhání – Spuštění se nezdařilo. Vlastnost Error při spuštění obvykle poskytne podrobnosti o tom, proč.
Dokončeno – spuštění bylo úspěšně dokončeno.
Zrušeno – Po provedení žádosti o zrušení je teď spuštění úspěšně zrušeno.


   run = experiment.submit(config)
   while run.get_status() not in ['Finished', 'Failed']: # For example purposes only, not exhaustive
       print('Run {} not in terminal state'.format(run.id))
       time.sleep(10)

get_steps

Získejte spuštění kroku pro všechny kroky kanálu, které byly dokončeny nebo spuštěny.

get_steps()

Návraty

Typ	Description
list	Seznam StepRun objektů.

get_tags

Získejte sadu značek pro spuštění.

get_tags()

Návraty

Typ	Description
dict	Slovník značek pro spuštění

publish_pipeline

Publikujte kanál a zpřístupnit ho pro opětovné spuštění.

Koncový bod kanálu můžete získat z objektu PublishedPipeline vráceného touto funkcí. Pomocí koncového bodu kanálu můžete kanál vyvolat z externích aplikací pomocí volání REST. Informace o ověřování při volání koncovýchbodůch https://aka.ms/pl-restep-auth

Původní kanál přidružený ke spuštění kanálu se použije jako základ publikovaného kanálu.

publish_pipeline(name, description, version, continue_on_step_failure=None, **kwargs)

Parametry

Name	Description
name Vyžadováno	str Název publikovaného kanálu.
description Vyžadováno	str Popis publikovaného kanálu.
version Vyžadováno	str Verze publikovaného kanálu.
continue_on_step_failure	bool Zda pokračovat v provádění dalších kroků v PipelineRun, pokud krok selže. Výchozí hodnota je False. Default value: None
kwargs Vyžadováno	dict Vlastní argumenty klíčových slov, vyhrazené pro budoucí vývoj

Návraty

Typ	Description
PublishedPipeline	Vytvořili jste publikovaný kanál.

save

Uložte kanál YAML do souboru.

save(path=None)

Parametry

Name	Description
path	str Cesta k uložení YAML do. Pokud je cesta adresář, uloží se soubor YAML kanálu na <cestě> nebo pipeline.yml. Pokud cesta není žádná, použije se aktuální adresář. Default value: None

Návraty

Typ	Description
None

wait_for_completion

Počkejte na dokončení tohoto spuštění kanálu.

Vrátí stav po čekání.

wait_for_completion(show_output=True, timeout_seconds=9223372036854775807, raise_on_error=True)

Parametry

Name	Description
show_output	bool Určuje, zda se má zobrazit stav spuštění kanálu v sys.stdout. Default value: True
timeout_seconds	int Počet sekund čekání před uplynutím časového limitu. Default value: 9223372036854775807
raise_on_error	bool Určuje, jestli se má při spuštění zobrazit chyba ve stavu selhání. Default value: True

Návraty

Typ	Description
str	Konečný stav.

Váš názor

Byla tato stránka užitečná?

Sdílet prostřednictvím

PipelineRun Třída

Konstruktor

Parametry

Poznámky

Metody

cancel

child_run

Parametry

Návraty

Výjimky

complete

Výjimky

fail

Výjimky

find_step_run

Parametry

Návraty

get

Parametry

Návraty

get_graph

Návraty

get_pipeline_output

Parametry

Návraty

get_pipeline_runs

Parametry

Návraty

get_status

Návraty

Poznámky

get_steps

Návraty

get_tags

Návraty

publish_pipeline

Parametry

Návraty

save

Parametry

Návraty

wait_for_completion

Parametry

Návraty

Váš názor