StepRun Osztály

Egy lépés futtatása egy Pipeline.

Ez az osztály használható a szülőfolyamat-futtatás és a folyamat által a lépésfuttatás elküldése után a futtatás részleteinek kezelésére, ellenőrzésére és lekérésére.

StepRun inicializálása.

Konstruktor

StepRun(experiment, step_run_id, pipeline_run_id, node_id, _service_endpoint=None, _is_reused=False, _current_node_id=None, _reused_run_id=None, _reused_node_id=None, _reused_pipeline_run_id=None, **kwargs)

Paraméterek

Name	Description
experiment Kötelező	Experiment A lépésfuttatás kísérletobjektuma.
step_run_id Kötelező	str A lépésfuttatás futtatási azonosítója.
pipeline_run_id Kötelező	str A szülőfolyamat-futtatás futtatási azonosítója.
node_id Kötelező	str A lépést jelképező csomópont azonosítója a gráfban.
_service_endpoint	str A végpont, amelyhez csatlakozni szeretne. Alapértelmezett érték: None
_is_reused	bool Azt jelzi, hogy ez a futtatás egy újrahasznált előző futtatás-e. Alapértelmezett érték: False
_current_node_id	str Újrafelhasznált csomópont esetén az aktuális gráf csomópontazonosítója. Alapértelmezett érték: None
_reused_run_id	str Az újrahasznált futtatási azonosító. Alapértelmezett érték: None
_reused_node_id	str Az újrafelhasznált csomópont azonosítója. Alapértelmezett érték: None
_reused_pipeline_run_id	str Az újrahasznált folyamat azonosítója. Alapértelmezett érték: None
experiment Kötelező	Experiment A lépésfuttatás kísérletobjektuma.
step_run_id Kötelező	str A lépésfuttatás futtatási azonosítója.
pipeline_run_id Kötelező	str A szülőfolyamat-futtatás futtatási azonosítója.
node_id Kötelező	str A lépést jelképező csomópont azonosítója a gráfban.
_service_endpoint Kötelező	str A végpont, amelyhez csatlakozni szeretne.
_is_reused Kötelező	bool Azt jelzi, hogy ez a futtatás egy újrahasznált előző futtatás-e.
_current_node_id Kötelező	str Újrafelhasznált csomópont esetén az aktuális gráf csomópontazonosítója.
_reused_run_id Kötelező
_reused_node_id Kötelező	str
_reused_pipeline_run_id Kötelező	str

Megjegyzések

A rendszer egy lépésfuttatást hoz létre egy beküldött PipelineRungyermekfuttatásként. A PipelineRun összes lépésfuttatásának lekérése az alábbiak szerint:

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

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

A futtatás által létrehozott futtatási adatok és naplók lekérésére használható get_details_with_logs .

A StepRun egy futtatás kimeneteinek letöltésére is használható. A get_outputs lépéskimenetek diktálásának lekérésére vagy a kimenet egyetlen get_output objektumának lekérésére használható StepRunOutput a megadott névvel. A megadott lépés kimenetét get_output_data közvetlenül is PortDataReference lekérheti.

Példa egy lépés kimenetének letöltésére az alábbiak szerint:

   from azureml.pipeline.core import PipelineRun, StepRun, PortDataReference

   pipeline_run = PipelineRun(experiment, "<pipeline_run_id>")
   step_run = pipeline_run.find_step_run("<step_name>")[0]
   port_data_reference = step_run.get_output_data("<output_name>")
   port_data_reference.download(local_path="path")

Metódusok

child_run	Gyermekfuttatás a lépésfuttatáshoz. Ez a metódus nem implementálva a StepRun esetében.
complete	A lépésfuttatás befejeződik. Ez a metódus nem implementálva a StepRun esetében.
fail	A lépés futtatása sikertelen. Ez a metódus nem implementálva a StepRun esetében.
get_details_with_logs	Adja vissza a futtatás állapotadatait a naplófájl tartalmával.
get_job_log	A lépésfuttatás aktuális feladatnaplójának kiírása.
get_output	Kérje le a csomópont kimenetét a megadott névvel.
get_output_data	A kimeneti adatok lekérése egy adott kimenetből.
get_outputs	A lépés kimeneteinek lekérése.
get_status	Kérje le a folyamatfuttatás legújabb állapotát a szolgáltatásból. A visszaadott gyakori értékek közé tartozik a "Futtatás", a "Kész" és a "Sikertelen".
get_stderr_log	A lépésfuttatás aktuális stderr-naplójának memóriaképe.
get_stdout_log	A lépésfuttatás aktuális stdout-naplójának kiírása.
wait_for_completion	Várja meg a lépés futtatásának befejezését. A várakozás utáni állapotot adja vissza.

child_run

Gyermekfuttatás a lépésfuttatáshoz. Ez a metódus nem implementálva a StepRun esetében.

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

Paraméterek

Name	Description
name	str A gyermek nem kötelező neve Alapértelmezett érték: None
run_id	str Nem kötelező run_id a gyermek számára, egyébként az alapértelmezettet használja Alapértelmezett érték: None
outputs	str Választható kimenetek könyvtára a gyermek nyomon követéséhez Alapértelmezett érték: None

Válaszok

Típus	Description
Run	A gyermek futása

Kivételek

Típus	Description
NotImplementedError

complete

A lépésfuttatás befejeződik. Ez a metódus nem implementálva a StepRun esetében.

complete()

Kivételek

Típus	Description
NotImplementedError

fail

A lépés futtatása sikertelen. Ez a metódus nem implementálva a StepRun esetében.

fail()

Kivételek

Típus	Description
NotImplementedError

get_details_with_logs

Adja vissza a futtatás állapotadatait a naplófájl tartalmával.

get_details_with_logs()

Válaszok

Típus	Description
dict	A futtatás állapotát adja vissza a naplófájl tartalmával

get_job_log

A lépésfuttatás aktuális feladatnaplójának kiírása.

get_job_log()

Válaszok

Típus	Description
str	A naplósztring.

get_output

Kérje le a csomópont kimenetét a megadott névvel.

get_output(name)

Paraméterek

Name	Description
name Kötelező	str A kimenet neve.

Válaszok

Típus	Description
StepRunOutput	A StepRunOutput a megadott névvel.

get_output_data

A kimeneti adatok lekérése egy adott kimenetből.

get_output_data(name)

Paraméterek

Name	Description
name Kötelező	str A kimenet neve.

Válaszok

Típus	Description
PortDataReference	A lépés kimeneti adatait képviselő PortDataReference.

get_outputs

A lépés kimeneteinek lekérése.

get_outputs()

Válaszok

Típus	Description
dict	A StepRunOutputs szótára, kulcsként a kimeneti névvel.

get_status

Kérje le a folyamatfuttatás legújabb állapotát a szolgáltatásból.

A visszaadott gyakori értékek közé tartozik a "Futtatás", a "Kész" és a "Sikertelen".

get_status()

Válaszok

Típus	Description
str	A legújabb állapot sztringként

Megjegyzések

• NotStarted – Ez egy ideiglenes állapotú ügyféloldali futtatási objektum, amely a felhőbeküldés előtt van

• Várólistán – A feladat várólistára van állítva.

• Futtatás – A feladat a számítási célban kezdett futni.

• Sikertelen – A futtatás sikertelen volt. A Futtatás hiba tulajdonsága általában részletesen ismerteti, hogy miért.

• Befejeződött – A futtatás sikeresen befejeződött.

• Megszakítva – A lemondási kérést követően a futtatás sikeresen megszakadt.

   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_stderr_log

A lépésfuttatás aktuális stderr-naplójának memóriaképe.

get_stderr_log()

Válaszok

Típus	Description
str	A naplósztring.

get_stdout_log

A lépésfuttatás aktuális stdout-naplójának kiírása.

get_stdout_log()

Válaszok

Típus	Description
str	A naplósztring.

wait_for_completion

Várja meg a lépés futtatásának befejezését.

A várakozás utáni állapotot adja vissza.

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

Paraméterek

Name	Description
show_output	bool show_output=True a sys.stdout folyamatfuttatási állapotát jeleníti meg. Alapértelmezett érték: True
timeout_seconds	int Az időtúllépés előtt várandó másodpercek száma. Alapértelmezett érték: 9223372036854775807
raise_on_error	bool Azt jelzi, hogy hibát jelez-e, ha a futtatás sikertelen állapotban van Alapértelmezett érték: True

Válaszok

Típus	Description
str	A végső állapot.

Attribútumok

pipeline_run_id

Adja vissza a lépésfuttatásnak megfelelő folyamatfuttatás azonosítóját.

Válaszok

Típus	Description
str	A PipelineRun azonosítója.