Sdílet prostřednictvím

StepRun Třída

Spuštění kroku v kroku Pipeline.

Tuto třídu lze použít ke správě, kontrole stavu a načítání podrobností o spuštění po odeslání nadřazeného spuštění kanálu a spuštění kanálu odešle spuštění kroku.

Inicializace stepRunu

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)

Parametry

Name Description
experiment
Vyžadováno
Experiment

Objekt experimentu spuštění kroku
step_run_id
Vyžadováno
str

ID spuštění kroku.
pipeline_run_id
Vyžadováno
str

ID spuštění nadřazeného kanálu.
node_id
Vyžadováno
str

ID uzlu v grafu, který představuje tento krok.
_service_endpoint
str

Koncový bod, ke kterému se chcete připojit.

Default value: None
_is_reused
bool

Určuje, jestli se jedná o opakované použití předchozího spuštění.

Default value: False
_current_node_id
str

U opakovaně používaného uzlu je ID uzlu v aktuálním grafu.

Default value: None
_reused_run_id
str

ID opakovaného spuštění.

Default value: None
_reused_node_id
str

ID opakovaně používaného uzlu.

Default value: None
_reused_pipeline_run_id
str

ID znovu použitého kanálu.

Default value: None
experiment
Vyžadováno
Experiment

Objekt experimentu spuštění kroku
step_run_id
Vyžadováno
str

ID spuštění kroku.
pipeline_run_id
Vyžadováno
str

ID spuštění nadřazeného kanálu.
node_id
Vyžadováno
str

ID uzlu v grafu, který představuje tento krok.
_service_endpoint
Vyžadováno
str

Koncový bod, ke kterému se chcete připojit.
_is_reused
Vyžadováno
bool

Určuje, jestli se jedná o opakované použití předchozího spuštění.
_current_node_id
Vyžadováno
str

U opakovaně používaného uzlu je ID uzlu v aktuálním grafu.
_reused_run_id
Vyžadováno
_reused_node_id
Vyžadováno
str
_reused_pipeline_run_id
Vyžadováno
str

Poznámky

StepRun se vytvoří jako podřízený běh odeslaného PipelineRunsouboru . Načtěte všechny stepRuns v PipelineRun 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>")
   step_runs = pipeline_run.get_steps()

Slouží get_details_with_logs k načtení podrobností o spuštění a protokolů vytvořených spuštěním.

StepRun se dá použít také ke stažení výstupů spuštění. Slouží get_outputs k načtení diktování výstupu kroku nebo k get_output načtení jednoho StepRunOutput objektu pro výstup se zadaným názvem. Můžete také použít get_output_data k přímému načtení výstupu PortDataReference zadaného kroku.

Příklad stažení výstupu kroku je následující:


   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")

Metody

child_run

Podřízené spuštění pro spuštění kroku Tato metoda není implementována pro StepRun.
complete

Dokončení pro spuštění kroku Tato metoda není implementována pro StepRun.
fail

Selhání pro spuštění kroku Tato metoda není implementována pro StepRun.
get_details_with_logs

Vrátí podrobnosti o stavu spuštění s obsahem souboru protokolu.
get_job_log

Vypíše aktuální protokol úloh pro spuštění kroku.
get_output

Získejte výstup uzlu s daným názvem.
get_output_data

Získejte výstupní data z daného výstupu.
get_outputs

Získejte výstupy kroku.
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_stderr_log

Vypíše aktuální protokol stderru pro spuštění kroku.
get_stdout_log

Vypíše aktuální protokol stdout pro spuštění kroku.
wait_for_completion

Počkejte na dokončení tohoto kroku.

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

child_run

Podřízené spuštění pro spuštění kroku Tato metoda není implementována pro StepRun.

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

Parametry

Name Description
name
str

Volitelný název podřízeného

Default value: None
run_id
str

Volitelné run_id pro podřízenou hodnotu, jinak použije výchozí

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é spuštění

Výjimky

Typ Description
NotImplementedError

complete

Dokončení pro spuštění kroku Tato metoda není implementována pro StepRun.

complete()

Výjimky

Typ Description
NotImplementedError

fail

Selhání pro spuštění kroku Tato metoda není implementována pro StepRun.

fail()

Výjimky

Typ Description
NotImplementedError

get_details_with_logs

Vrátí podrobnosti o stavu spuštění s obsahem souboru protokolu.

get_details_with_logs()

Návraty

Typ Description
dict

Vrátí stav spuštění s obsahem souboru protokolu.

get_job_log

Vypíše aktuální protokol úloh pro spuštění kroku.

get_job_log()

Návraty

Typ Description
str

Řetězec protokolu.

get_output

Získejte výstup uzlu s daným názvem.

get_output(name)

Parametry

Name Description
name
Vyžadováno
str

Název výstupu

Návraty

Typ Description
StepRunOutput

StepRunOutput s daným názvem.

get_output_data

Získejte výstupní data z daného výstupu.

get_output_data(name)

Parametry

Name Description
name
Vyžadováno
str

Název výstupu

Návraty

Typ Description
PortDataReference

PortDataReference představující výstupní data kroku.

get_outputs

Získejte výstupy kroku.

get_outputs()

Návraty

Typ Description
dict

Slovník StepRunOutputs s názvem výstupu jako klíčem.

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.

  • Zařazeno do fronty – úloha je zařazena do fronty.

  • 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_stderr_log

Vypíše aktuální protokol stderru pro spuštění kroku.

get_stderr_log()

Návraty

Typ Description
str

Řetězec protokolu.

get_stdout_log

Vypíše aktuální protokol stdout pro spuštění kroku.

get_stdout_log()

Návraty

Typ Description
str

Řetězec protokolu.

wait_for_completion

Počkejte na dokončení tohoto kroku.

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

show_output=True zobrazuje 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

Označ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.

Atributy

pipeline_run_id

Vrátí ID spuštění kanálu odpovídající tomuto kroku.

Návraty

Typ Description
str

ID spuštění kanálu.