StepRun Klas
Een uitvoering van een stap in een Pipeline.
Deze klasse kan worden gebruikt voor het beheren, controleren van de status en het ophalen van uitvoeringsdetails zodra de bovenliggende pijplijnuitvoering is verzonden en de pijplijn de stapuitvoering heeft verzonden.
Initialiseer een StepRun.
- Overname
-
StepRun
Constructor
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)
Parameters
Name | Description |
---|---|
experiment
Vereist
|
Het experimentobject van de stapuitvoering. |
step_run_id
Vereist
|
De uitvoerings-id van de stapuitvoering. |
pipeline_run_id
Vereist
|
De uitvoerings-id van de bovenliggende pijplijnuitvoering. |
node_id
Vereist
|
De id van het knooppunt in de grafiek die deze stap vertegenwoordigt. |
_service_endpoint
|
Het eindpunt waarmee u verbinding wilt maken. Default value: None
|
_is_reused
|
Hiermee wordt aangegeven of deze uitvoering een vorige uitvoering opnieuw is gebruikt. Default value: False
|
_current_node_id
|
Voor een opnieuw gebruikt knooppunt, de knooppunt-id in de huidige grafiek. Default value: None
|
_reused_run_id
|
De opnieuw gebruikte uitvoerings-id. Default value: None
|
_reused_node_id
|
De opnieuw gebruikte knooppunt-id. Default value: None
|
_reused_pipeline_run_id
|
De opnieuw gebruikte pijplijn-id. Default value: None
|
experiment
Vereist
|
Het experimentobject van de stapuitvoering. |
step_run_id
Vereist
|
De uitvoerings-id van de stapuitvoering. |
pipeline_run_id
Vereist
|
De uitvoerings-id van de bovenliggende pijplijnuitvoering. |
node_id
Vereist
|
De id van het knooppunt in de grafiek die deze stap vertegenwoordigt. |
_service_endpoint
Vereist
|
Het eindpunt waarmee u verbinding wilt maken. |
_is_reused
Vereist
|
Hiermee wordt aangegeven of deze uitvoering een vorige uitvoering opnieuw is gebruikt. |
_current_node_id
Vereist
|
Voor een opnieuw gebruikt knooppunt, de knooppunt-id in de huidige grafiek. |
_reused_run_id
Vereist
|
|
_reused_node_id
Vereist
|
|
_reused_pipeline_run_id
Vereist
|
|
Opmerkingen
Een StepRun wordt gemaakt als een onderliggende uitvoering van een verzonden PipelineRun. Haal alle StepRuns in een PipelineRun als volgt op:
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()
Gebruik get_details_with_logs om de details van de uitvoering en logboeken op te halen die door de uitvoering zijn gemaakt.
StepRun kan ook worden gebruikt om de uitvoer van een uitvoering te downloaden. Gebruik get_outputs om een dicteerfunctie van de stapuitvoer op te halen of gebruik get_output om het ene StepRunOutput object voor de uitvoer op te halen met de opgegeven naam. U kunt ook gebruiken get_output_data om de voor de PortDataReference opgegeven stapuitvoer rechtstreeks op te halen.
Een voorbeeld van het downloaden van een stapuitvoer is als volgt:
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")
Methoden
child_run |
Onderliggende uitvoering voor stapuitvoering. Deze methode is niet geïmplementeerd voor StepRun. |
complete |
Voltooi de uitvoering van de stap. Deze methode is niet geïmplementeerd voor StepRun. |
fail |
Mislukt voor het uitvoeren van de stap. Deze methode is niet geïmplementeerd voor StepRun. |
get_details_with_logs |
Retourneer de statusdetails van de uitvoering met de inhoud van het logboekbestand. |
get_job_log |
Dump het huidige taaklogboek voor de stapuitvoering. |
get_output |
Haal de uitvoer van het knooppunt op met de opgegeven naam. |
get_output_data |
Haal de uitvoergegevens op van een bepaalde uitvoer. |
get_outputs |
Haal de uitvoer van de stap op. |
get_status |
Haal de meest recente status van de pijplijnuitvoering op uit de service. Veelvoorkomende geretourneerde waarden zijn 'Wordt uitgevoerd', 'Voltooid' en 'Mislukt'. |
get_stderr_log |
Dump het huidige stderr-logboek voor de stapuitvoering. |
get_stdout_log |
Dump het huidige stdout-logboek voor de stapuitvoering. |
wait_for_completion |
Wacht tot de uitvoering van deze stap is voltooid. Retourneert de status na de wachttijd. |
child_run
Onderliggende uitvoering voor stapuitvoering. Deze methode is niet geïmplementeerd voor StepRun.
child_run(name=None, run_id=None, outputs=None)
Parameters
Name | Description |
---|---|
name
|
Optionele naam voor het kind Default value: None
|
run_id
|
Optionele run_id voor het kind, anders wordt standaard gebruikt Default value: None
|
outputs
|
Optionele uitvoermap om bij te houden voor het onderliggende item Default value: None
|
Retouren
Type | Description |
---|---|
De onderliggende uitvoering |
Uitzonderingen
Type | Description |
---|---|
complete
Voltooi de uitvoering van de stap. Deze methode is niet geïmplementeerd voor StepRun.
complete()
Uitzonderingen
Type | Description |
---|---|
fail
Mislukt voor het uitvoeren van de stap. Deze methode is niet geïmplementeerd voor StepRun.
fail()
Uitzonderingen
Type | Description |
---|---|
get_details_with_logs
Retourneer de statusdetails van de uitvoering met de inhoud van het logboekbestand.
get_details_with_logs()
Retouren
Type | Description |
---|---|
Retourneert de status voor de uitvoering met de inhoud van het logboekbestand |
Uitzonderingen
Type | Description |
---|---|
get_job_log
Dump het huidige taaklogboek voor de stapuitvoering.
get_job_log()
Retouren
Type | Description |
---|---|
De logboektekenreeks. |
Uitzonderingen
Type | Description |
---|---|
get_output
Haal de uitvoer van het knooppunt op met de opgegeven naam.
get_output(name)
Parameters
Name | Description |
---|---|
name
Vereist
|
Naam van de uitvoer. |
Retouren
Type | Description |
---|---|
De StepRunOutput met de opgegeven naam. |
Uitzonderingen
Type | Description |
---|---|
get_output_data
Haal de uitvoergegevens op van een bepaalde uitvoer.
get_output_data(name)
Parameters
Name | Description |
---|---|
name
Vereist
|
Naam van de uitvoer. |
Retouren
Type | Description |
---|---|
De PortDataReference die de uitvoergegevens van de stap vertegenwoordigt. |
Uitzonderingen
Type | Description |
---|---|
get_outputs
Haal de uitvoer van de stap op.
get_outputs()
Retouren
Type | Description |
---|---|
Een woordenlijst van StepRunOutputs met de uitvoernaam als sleutel. |
Uitzonderingen
Type | Description |
---|---|
get_status
Haal de meest recente status van de pijplijnuitvoering op uit de service.
Veelvoorkomende geretourneerde waarden zijn 'Wordt uitgevoerd', 'Voltooid' en 'Mislukt'.
get_status()
Retouren
Type | Description |
---|---|
De meest recente status als tekenreeks |
Uitzonderingen
Type | Description |
---|---|
Opmerkingen
NotStarted - Dit is een tijdelijke status waarin run-objecten aan de clientzijde zich bevinden voordat ze in de cloud worden verzonden
In wachtrij: de taak wordt in de wachtrij geplaatst.
Uitvoeren: de taak wordt uitgevoerd in het rekendoel.
Mislukt: de uitvoering is mislukt. Meestal geeft de eigenschap Error bij een uitvoering details over de reden.
Voltooid: de uitvoering is voltooid.
Geannuleerd: na de annuleringsaanvraag is de uitvoering nu geannuleerd.
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
Dump het huidige stderr-logboek voor de stapuitvoering.
get_stderr_log()
Retouren
Type | Description |
---|---|
De logboektekenreeks. |
Uitzonderingen
Type | Description |
---|---|
get_stdout_log
Dump het huidige stdout-logboek voor de stapuitvoering.
get_stdout_log()
Retouren
Type | Description |
---|---|
De logboektekenreeks. |
Uitzonderingen
Type | Description |
---|---|
wait_for_completion
Wacht tot de uitvoering van deze stap is voltooid.
Retourneert de status na de wachttijd.
wait_for_completion(show_output=True, timeout_seconds=9223372036854775807, raise_on_error=True)
Parameters
Name | Description |
---|---|
show_output
|
show_output=True toont de uitvoeringsstatus van de pijplijn op sys.stdout. Default value: True
|
timeout_seconds
|
Het aantal seconden dat moet worden gewacht voordat er een time-out optreedt. Default value: 9223372036854775807
|
raise_on_error
|
Geeft aan of er een fout moet worden gegenereerd wanneer de uitvoering de status Mislukt heeft Default value: True
|
Retouren
Type | Description |
---|---|
De uiteindelijke status. |
Uitzonderingen
Type | Description |
---|---|
Kenmerken
pipeline_run_id
Retourneert de id van de pijplijnuitvoering die overeenkomt met deze stapuitvoering.
Retouren
Type | Description |
---|---|
De pipelineRun-id. |